Fetching

专注于大数据、机器学习、网络安全及美食

Flink debug

2019-01-15 13:50
239
0

Flink是可以支持本地调试的,本地调试的方式非常简单,就是在创建environment时创建localEnvironment即可。 代码如下所示: 创建localEnvironent之后,在IDEA

Flink事件时间和水印

2019-01-14 10:50
412
0

1.概览 处理时间/系统时间/进入时间 Flink在Streaming程序中,提供了不同的时间概念。 处理时间:处理时间代表着在执行相应操作时的系统时间。 当一个Streaming程序以处理时间运行时

Flink连接Kafka的实现原理

2019-01-10 17:54
430
0

Apache Flink Streaming支持多种数据源,第三方连接器列表如下: Apache Kafka Amazon Kinesis Streams RabbitMQ Apache NiFi T