什么是位运算? 程序中的所有数在计算机内存中都是以二进制的形式储存的。位运算说穿了,就是直接对整数在内存中的二进制位进行操作。比如,and运算本来是一个逻辑运算符,但整数与整数之间也可以进行and运算。举个例子,6的二进制是110,11的二进制是1011,那么6 and 1...
Continue reading一. 机器数和真值 1、机器数 一个数在计算机中的二进制表示形式, 叫做这个数的机器数。机器数是带符号的,在计算机用一个数的最高位存放符号, 正数为0, 负数为1. 比如,十进制中的数 +3 , 计算机字长为8位, 转换成二进制就是00000011。如果是 -3 , 就是 ...
Continue reading一.RAID定义 RAID(Redundant Array of Independent Disk 独立冗余磁盘阵列)技术是加州大学伯克利分校1987年提出,最初是为了组合小的廉价磁盘来代替大的昂贵磁盘,同时希望磁盘失效时不会使对数据的访问受损 失而开发出一定水平的数据保护...
Continue readingBucketing 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 reading