Kudu与Hbase Hbase是列族存储,一般情况下定义一个列族,然后列族中多个列,这样会更加接近于行存储,schema的定义比较宽松,可以随时添加列;Kudu是真正的列式...
Kudu与Hbase Hbase是列族存储,一般情况下定义一个列族,然后列族中多个列,这样会更加接近于行存储,schema的定义比较宽松,可以随时添加列;Kudu是真正的列式...
Enum<E extends Enum<E>> 的解释 例如定义如下抽象类,然后实现类就只能是 X extends Enum<X> 的模式,如下 这样限定子类Color定义的...
线程的状态转换 synchronized锁的解释https://blog.csdn.net/xiao__gui/article/details/8188833
泛型的参数必须是类类型,不能是简单类型,如int是不行的,要Integer 泛型饿类型个数可以是多个 可以使用extends关键字限制泛型的类型 可以通配符限制泛型的类型 泛...
集合类的继承关系 常用的几个实现类HashSet:没有排序的Set实现类,平时可以使用 TreeSet:实现类SortedSet接口的Set实现类,需要输出排序结果的时候使用...
自定义异常 class BitsonExceptionextends Exception {BitsonException(String msg) {super(msg);}...
package com.erised.flink.streaming;class O {class P {}}public class M {public static vo...
接口的定义,如下, interface I {int str1 =2;// 接口里定义的变量自动是static和final的abstract void inter();// ...
猫和狗两个类 class Cat {}class Dog {} 假如主人要喂的话,在没有多态的情况下,主人要实现两个方法,分别针对猫和狗来喂 class Master { ...
安装的是dse版本,而且暂时是单节点安装,过程中出了点小问题 安装步骤如下: 首先,按照文档安装,大概是安装jdk和dse然后,就有点tricky的地方了,官方安装时文档里一...
参考 FlinkData Streaming Fault Tolerance High-throughput, low-latency, and exactly-once s...
参考 24/7 Spark Streaming on YARN in Production Long-running Spark Streaming Jobs on YARN...
参考Flink 原理与实现:如何处理反压问题
参考 漫谈系列
参考datastax doc cassandra internals 主要介绍了cassandra的读写机制和一致性支持 读写机制 - write 和hbase的区别不大,基...
将数据处理的概念拆分成dataflow model中的四个问题:what, where,when,how Whatresults are calculated? -trans...
花了一天时间才看完了Tyler Akidau写的两篇关于流处理的文章,一是我英语一般,二是他用的词我也觉得比较生,所以理解的比较慢,三是看文章的环境比较嘈杂,难以专注。看之前...
最近少写了日记,今天做了两件事 1. 听了linkin上的一个流数据处理的课程,主要是一些基本概念和四个case study,分别针对不同的需求设计流处理架构,链接在这里。有...
social media sentiment analysis real time fraud detetcion website product recommendatio...