clickhouse中的lead和lag实现有多种方法，在标准的SQL中使用的windows function即可实现。示例数据：CREATE TABLE llexample (g Int32,a Date )ENGINE = Memory;INSERT INTO llexample SELECTnumber % 3,toDate('2020-01-01') + numberFROM number

ctrl+c中断ctrl+a move the head of command linectrl+e move the tail of command linectrl+u 删除光标前面所有字符相当于VIM里d shift+^ctrl+k 删除光标后面所有字符相当于VIM里d shift+$ctrl+d 删除光标所在位置上的字符相当于VIM里x或者dlctrl+h 删除光标

Hadoop集群配置完成，web监控界面的50070和50030端口不需用户验证即可访问，对生产环境是不容许的，需要加上安全机制。1、修改core-site.xml，增加如下内容，配置完成后拷贝到其他节点上。       hadoop.http.filter.initializers    org.apache.hadoop.security.AuthenticationFilt

项目要结束了，最近在整理项目的相关文档，之前项目中在用hadoop jar **.jar提交作业时，设置了些公共依赖jar包到CLASSPATH中，这样算子在打包时就不需要把很多jar包再打进去离开 。在hadoop-env.sh中和mapreduce.application.classpath、yarn.application.classpath将jar都设置进去了，这样在本地执行hadoo

文章内容包含Kafka未进行序列化生产消费java示例，和使用Avro序列化数据进行生产和消费的示例，掌握这些之后就对Kafka的生产消费有基本开发基础。1.未序列化生产者示例：import java.util.Properties;import kafka.javaapi.producer.Producer;import kafka.producer.KeyedMessa