学习 Druid(三):Kafka 数据摄入

Druid 支持两种 Kafka 数据摄入方式: Push 通过 Tranquility; Pull 通过 Kafka Indexing Service。 Tranquility TODO Kafka Indexing Service 1. 编辑配置文件 编辑 Overload 和 MiddleManager 的 conf/druid/ »

Flink 源码分析(三):生成 StreamGraph

更新至 Flink 1.9.0 版本 下面以 Flink 工程自带的 wordcount 程序为例,分析应用执行。 执行环境 创建执行环境: final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); org.apache.flink.streaming.api.environment.StreamExecutionEnvironment »

学习 Kubernetes(六):CronJob

CronJob 是 Kubernetes 用于运行定时任务的资源。 Cron 表达式 在 CronJob 中,Cron 表达式表示什么时候,Job 表示做什么。 Cron 表达式,包含了 5 个必填字段和 1 个选填字段,字段间使用空格分隔。 Cron 表达式字段说明: 字段 是否必填 值域 »