1.概述 转载：Flink 源码之时间处理 2.Flink支持的时间类型 EventTime： 每条数据都携带时间戳。Operator处理数据的时候所有依赖时间的操作依据数据携带的时间戳。可以支持乱序数据的处理。时间戳信息可以在数据源产生数据的时候指定（SourceFunction的中调用context的collectWit
Arrays.asList 创建的 ArrayList 的使用 Arrays.asList() 方法生成的 ArrayList 类对象，在调用 add()，remove() 等方法时会报错 public static void main(String[] args) { List<String> list = Arrays.asList("Java", "C++", "Python"); list.add("C#&quo
笔记： 队列：（offer，poll，element ） 队列是只允许在一端进行插入操作，而在另一端进行删除操作的线性表。 ——我们把允许删除的一端称为队首（front），插入的一端称为队尾（rear） ——不含任何数据元素的队列称为空队列 ——队列是一种先进先出（First In Last Out）的线性表，简称FIFO ——队列本身是
例子 我们经常坐电梯都知道，电梯有多种状态，就按最简单的来说，包括运行状态、停止状态、开门状态、闭门状态。下面就以电梯运行为例，举一个具体的实例，UML图如下： public abstract class LiftState { protected LiftContext LiftContext; public void SetC
例子 访问者模式 Element -> AbsPlatform -》 User,Guild,GuildMember Visitor -> AbsVisitor -》 教会管理员，教会创建者，平台管理员 ObjectStructure -> BusinessReport public abstract class AbsPlatform { /// <summary> /// visitor 获取数据
数据结构与算法—双端队列的实现 接口代码 接口 Dequeue接口 package p1.接口; public interface Dequeue<E> extends Queue<E> { public void addFirst(E element); public void addLast(E element); public E removeFirst(); public E reomveLast();
Kotlin 接口与 Java 8 类似，使用 interface 关键字定义接口，允许方法有默认实现： interface MyInterface { fun bar() // 未实现 fun foo() { //已实现 // 可选的方法体 println("foo") } } 实现接口 一个类或者对象可以实现一个或多个接口。 class Child : MyInterface { override f
目录 队列队列的定义队列的理解代码 文件夹的遍历（用对列实现，也就是层序遍历）思路代码 栈和队列的相互转换栈实现队列思路代码 队列实现栈思路代码 回顾ArrayQueue优化1、头指针后移2、头尾指针移动时，按循环移动(Rear+1)%n3、牺牲一个存储单元思考？ 循环队列ArrayLoopQueue
文章目录 中缀表达式转后缀表达式栈实现后缀表达式十进制转十六进制十六进制转十进制回文字符判断括号匹配问题双端栈队列queue接口定义结构实现 数据结构文件遍历栈实现队列队列实现栈循环队列双端栈接口结构 中缀表达式转后缀表达式 public class InfixToSuffix {
队列的的定义 队列是只允许在一端进行插入操作，而在另一端进行删除操作的线性表 •我们把允许删除的一端称为队首（front），插入的一端称为队尾（rear） •不含任何数据元素的队列称为空队列 •队列是一种先进先出（First In Last Out）的线性表，简称FIFO •队列本身是一个线性表，其数据
借口 package p1.List; public interface Dequeue <E> extends Queue<E>{ public void addFirst(E element); public void addLast(E element); public void removeLast(E element); public E removeFirst(); public E getFirst(); pub
自定义拦截器实现ProducerInterceptor package com.wangbiao.kafka.interceptor; import org.apache.kafka.clients.producer.ProducerInterceptor; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.kafka.clients.producer.RecordMetadata;
ActivityUtil.java public class ActivityUtil { private static Stack<Activity> activityStack = new Stack<>(); private static final MyActivityLifecycleCallbacks INSTANCE = new MyActivityLifecycleCallbacks(); public ActivityUtil() {
Material组件库中提供了一个MaterialPageRoute组件，它可以使用和平台风格一致的路由切换动画，如在iOS上会左右滑动切换，而在Android上会上下滑动切换。现在，我们如果在Android上也想使用左右切换风格，该怎么做？一个简单的作法是可以直接使用CupertinoPageRoute，如： Navigator.push(cont
1 private RadioGroup mrg1; 2 @Override 3 protected void onCreate(Bundle savedInstanceState) { 4 super.onCreate(savedInstanceState); 5 setContentView(R.layout.activity_radio_button); 6 mrg1=findViewById(R.id.rg_1); 7
简介：本文结合个人在架构设计上的思考和理解，介绍如何从0到1设计一个大型Android项目架构。 作者 | 璞珂 来源 | 阿里技术公众号 前言：本文结合个人在架构设计上的思考和理解，介绍如何从0到1设计一个大型Android项目架构。 一 引导 本文篇幅较长，可结合下表引导快速了解全文主脉
WindowManager.LayoutParams.SOFT_INPUT_STATE_ALWAYS_HIDDEN); KeyboardView keyboardView = (KeyboardView) findViewById(R.id.keyboardview); builder = new KeyboardBuilder(this, keyboardView, R.xml.keys_layout); EditText editCustomIME = (EditText) findViewById
一、 Overload(重载) 在C++中，函数重载：函数名相同，但参数不同（包括类型、顺序不同），与函数返回值类型无关，例如Example中的f。满足条件： 相同的范围（在同一个类中） 函数名字相同 参数不同 二、Override（覆盖） 在C++中，函数覆盖：对于基类中存在的一个virtual修饰的函数（例如Example中Base
一、SpringSecurity 动态授权 上篇文章我们介绍了SpringSecurity的动态认证，上篇文章就说了SpringSecurity 的两大主要功能就是认证和授权，既然认证以及学习了，那本篇文章一起学习了SpringSecurity 的动态授权。 上篇文章地址：https://blog.csdn.net/qq_43692950/article/detail
接口类： public interface UserService {// 常量的默认前缀是 public static final int age=3;// 接口中所有的方法都是抽象的，默认前缀是 public abstact void add(); void delete(); void update(); void query();} 实现类：接口中可以实现多继承，并且接
目录 1、模板方法模式模板方法模式的钩子方法模板方法模式在 Spring 框架应用的源码分析 2、命令模式Spring 框架的 JdbcTemplate 就使用到了命令模式 3、访问者模式4、迭代器模式5、观察者模式 1、模板方法模式 基本介绍 1)模板方法模式（Template Method Pattern），又叫模
1 方法重写 1.1 方法重写的概念 子类继承了父类，子类就得到了父类的某个方法。但是子类觉得父类的这个方法不好用或者无法满足自己的需求。子类重写一个与父类申明一样的方法来覆盖父类的该方法，子类的这个方法就进行了方法重写。声明不变，重新实现 1.2 方法重写的校验注解：@Override
actuator 去掉 按照url查询数据 @Bean @ConditionalOnWebApplication(type = ConditionalOnWebApplication.Type.REACTIVE) public SgWebFluxTagsProvider webFluxRequestProvider() { return new SgWebFluxTagsProvider(); } @Bean @Condit
一、整合步骤 本文主要讲的是如何整合zuul网关，“基于SpringBoot整合SpringCloud微服务框架--Eureka注册中心及Feign远程调用/Ribbon负载均衡及Hystrix熔断器”请参考我的上一篇有关springcloud的博客：https://www.cnblogs.com/lkw-cnblogs/p/15764195.html，本文也是基于它的
Button buttonLeft.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View view) { display.setText(R.string.button1); } }); Switch aSwitch.setOnCheckedChangeListen
