连击 天
fork: star:
Flink版本: Flink v1.8 官网页面导航: Application Development > Streaming (DataStream API) > State & Fault Tolerance > Working with State State存活时长(TTL) 任何类型的Keyed State...
MySQL version: 5.7 点击进入官方文档 14.6.6 Redo Log redo log是一种基于磁盘的数据结构,用于在崩溃恢复期间纠正由不完整事务写入的数据。在正常操作期间,redo log编码那些通过SQL语句或...
Kafka版本:1.0.x 点击进入官网文档 name type default valid values description 释义 bootstrap.servers list A list of host/port pairs to use for establishing the initial connectio...
Spark version:2.4.3 name default meaning 释义 spark.dynamicAllocation.enabled false Whether to use dynamic resource allocation, which scales the number of executors registered ...
总结 setStartFromEarliest() 从所有分区的最早的offset开始读取。 setStartFromLatest() 从所有分区的最近的offset开始读取。 setStartFromTimestamp(long startupOffsetsTimestamp)。 从指...
7.2.4 并行度控制 Sqoop并行地从大多数数据库源导入数据。您可以使用-m或--num-mappers参数指定用于执行导入的map任务(并行进程)的数量。每个参数都取一个整数值,该整数值对应于要使用的并行...
上传azkaban-3.60.0-bin.zip 解压azkaban-3.60.0-bin.zip unzip azkaban-3.60.0-bin.zip 创建软连接 ln -s azkaban-3.60.0-bin azkaban 进入主目录 cd azkaban 查看程序文件 ls 显示如下 az...
下载源码包: azkaban-3.60.0.zip https://github.com/azkaban/azkaban/releases 解压源码包 unzip azkaban-3.60.0.zip cd azkaban-3.60.0/ SQL文件: cd azkaban-db/ ../gradlew installDist...
CDH版本:5.7.0 新Kafka版本:1.0.1 一、下载Kafka parcel文件 http://archive.cloudera.com/kafka/parcels/3.1.1.2/ KAFKA-3.1.1-1.3.1.1.p0.2-sles11.parcel KAFKA-3.1.1-1.3.1.1.p0.2-sle...
使用CopyTable进行HBase表备份 $HBASE_HOME/bin/hbase org.apache.hadoop.hbase.mapreduce.CopyTable --new.name=newtable --peer.adr=zookeeperhbase.zookeeper.quorum:2181:/hbase oldtabl...
看到一个kafka官网文档翻译的网站,很不错。附上链接: Kafka_2.11-0.10.1.0官方文档翻译
Hive中日期格式转换,可参考下面的例子 from_unixtime(unix_timestamp('20170608111213', 'yyyyMMddHHmmss'), 'yyyy-MM-dd HH:mm:ss')......
没有更多内容
加载失败,请刷新页面
文章删除后无法恢复,确定删除此文章吗?
动弹删除后,数据将无法恢复
评论删除后,数据将无法恢复