0x0 hive命令启动hive --service metastore #启动元数据库 hive --service hiveserver2 #启动hiveserver2 hiveservices.sh start #通过脚本启动 bin

0x0 hive命令启动hive --service metastore #启动元数据库 hive --service hiveserver2 #启动hiveserver2 hiveservices.sh start #通过脚本启动 bin

0x0 hive命令启动hive --service metastore #启动元数据库 hive --service hiveserver2 #启动hiveserver2 hiveservices.sh start #通过脚本启动 bin

0x0 Flink的容错机制1.一致性检查点(checkpoint) 图为一个计算流,计算根据流中的数据将其中的奇数与偶数进行分流统计 Flink故障恢复机制的核心,就是应用状态的一致性检查点 有状态流应用的一致性检查点,其实就是所有任务的

Hadoop下的数据存储格式LZO0x1 为什么要使用压缩技术?压缩技术能够有效减少底层存储系统(HDFS)读写字节数. 压缩提高了网络带宽和磁盘空间的效率 MR中的场景 (I/O,网络数据传输,Shuffle,Merge) 用CPU换I/

0x1 Long累加器的使用object selfAccumulator { def main(args: Array[String]): Unit = { val sc = new SparkContext