-
使用Cloud Map
-
test nginx: nginx: [alert] mmap(MAP
-
Flink Join样例程序(Java)
-
使用Kafka
-
使用Kafka
-
Kafka连接
-
Spark Structured Streaming样例程序(Java)
-
使用Kafka
-
创建Kafka
-
配置Kafka/DMS Kafka源端参数
-
使用Kafka Eagle对接MRS Kafka
-
Flink Join样例程序(Java)
在Flink应用中,调用flink-connector-kafka模块的接口,生产并消费数据。 代码样例 用户在开发前需要使用对接安全模式的Kafka,则需要引入 FusionInsight 的kafka-clients-*.jar,该jar包可在Kafka客户端目录下获取。 下面列出producer和consumer,以及Flink
来自:帮助中心 -
Spark Structured Streaming样例程序(Java)
-
Flink Join样例程序(Java)
-
structured streaming功能与可靠性介绍
-
structured streaming功能与可靠性介绍
-
structured streaming功能与可靠性介绍
-
Spark Structured Streaming样例程序(Java)
-
Spark Structured Streaming样例程序(Java)
-
Java样例代码
-
重启Kafka实例