Bucketing File Sink 创建一个默认的bucketing sink,sink到一个由时间作为切分的滚动的文件 DataStream<String> input = ...; //只需要一个文件存储的路径 input.addSink(new Buc...
Continue readingServiceLoader是什么? ServiceLoader：一个简单的服务提供者加载设施。服务 是一个熟知的接口和类（通常为抽象类）集合。服务提供者 是服务的特定实现。提供者中的类通常实现接口，并子类化在服务本身中定义的子类。服务提供者可以以扩展的形式安装在 Java ...
Continue readinghttp://kafka.apache.org/0101/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html
Continue reading在同一个项目中使用同一工具的不同版本会产生冲突,可以通过改变包名来解决冲突,因为包的本来用途就是解决同名问题. 下面是shade kafka的pom文件: <?xml version="1.0" encoding="UTF-8"?> <project xm...
Continue reading设置从指定offset开始读取 在Flink 1.3.0及以上可以使用setStartFromSpecificOffsets设置从指定offset开始读取 Fault Tolerance 开启checkpoint即可 offset提交行为 如果checkpoint被禁用,F...
Continue reading1. 如何查看Linux系统当前状态 cpu, io, memory, network 进程列表，查找特定进程pid，进程的cpu, io, memory使用情况， 系统的打开文件句柄数，线程数，当前用户的打开文件句柄数，线程数 java进程 进程pid，内存使用情况，JV...
Continue reading使Flink输出的数据在多个partition中均匀分布 FlinkKafkaProducerBase的子类可以使用默认的KafkaPartitioner FixedPartitioner(只向partition 0中写数据)也可以使用自己定义的Partitioner(继承...
Continue reading接口改善 接口中可以定义默认方法和静态方法 interface A{ public default void Sf(){ System.out.println("A.Sf()"); } public static int name(...
Continue reading