Flink读数据 addSource

1.首先创建数据源
Flink 生成数据源

2.消费数据源

package com.claroja;import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;public class ConsumerFromSensorSource {public static void main(String[] args) throws Exception {StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.setParallelism(1);DataStream<SensorReading> stream = env.addSource(new SensorSource());stream.print();env.execute();}
}/*
SensorReading{id='sensor_0', timestamp=1607780932062, temperature=1.308847778859833}
SensorReading{id='sensor_1', timestamp=1607780932062, temperature=1.308847778859833}
SensorReading{id='sensor_2', timestamp=1607780932062, temperature=1.308847778859833}
SensorReading{id='sensor_3', timestamp=1607780932062, temperature=1.308847778859833}
SensorReading{id='sensor_4', timestamp=1607780932062, temperature=1.308847778859833}
SensorReading{id='sensor_5', timestamp=1607780932062, temperature=1.308847778859833}
SensorReading{id='sensor_6', timestamp=1607780932062, temperature=1.308847778859833}
SensorReading{id='sensor_7', timestamp=1607780932062, temperature=1.308847778859833}
SensorReading{id='sensor_8', timestamp=1607780932062, temperature=1.308847778859833}
SensorReading{id='sensor_9', timestamp=1607780932062, temperature=1.308847778859833}
SensorReading{id='sensor_0', timestamp=1607780932172, temperature=2.190754491899719}*/

Flink读数据 addSource相关推荐

阿里云大学Apache Flink大数据学习笔记
之前有看过一些基础的大数据课程,现在又回来发现这里的课程更新还是蛮快的,讲的内容干货也很多,继续学习一下,下面是一些主要内容说明. 地址:https://developer.aliyun.com/le ...
10.STM32中用I2C接口发送数据到EEPROM寄存器在从此寄存器读数据
10.STM32中用I2C接口发送数据到EEPROM寄存器在从此寄存器读数据.
flink 写入到es_《从0到1学习Flink》—— Flink 写入数据到 Kafka
前言之前文章 <从0到1学习Flink>-- Flink 写入数据到 ElasticSearch 写了如何将 Kafka 中的数据存储到 ElasticSearch 中,里面其实就已经用 ...
flink实时同步mysql_基于Canal与Flink实现数据实时增量同步(一)
点击上方蓝色字体,关注我 canal是阿里巴巴旗下的一款开源项目,纯Java开发.基于数据库增量日志解析,提供增量数据订阅&消费,目前主要支持了MySQL(也支持mariaDB). 准备配置 ...
《从0到1学习Flink》—— Flink 写入数据到 ElasticSearch
前言前面 FLink 的文章中我们已经介绍了说 Flink 已经有很多自带的 Connector. 1.<从0到1学习Flink>-- Data Source 介绍 2.<从0到1 ...
centos7安装flink集群_《从0到1学习Flink》—— Flink 写入数据到 Kafka
前言之前文章 <从0到1学习Flink>-- Flink 写入数据到 ElasticSearch 写了如何将 Kafka 中的数据存储到 ElasticSearch 中,里面其实就已经用 ...
如何从io.Reader 中读数据
女主宣言 Go语言以其本身具有的高并发特性,在云计算开发中,得到了广泛的应用,也深受广大开发者的欢迎.但是大家对go语言真的理解了么?本文作者经过对go语言的多年实践应用,现对go语言中如何从io.R ...
python将csv装入mysql_python 从csv读数据到mysql的实例
如下所示: import csv import sys,os import MySQLdb def read_csv(filename): with open(filename) as f: f_cs ...
【kafka】flink 发送数据到 kafka 报错 Memory records is not writable
1.场景1 1.1 概述本次环境,kafka的版本为0.9.0.1,主要情况是flink写入数据到kafka shell端是可以发送的,我的程序重启后也是好的,运行一端时间后消息就发不出去了然后程 ...

Flink读数据 addSource

Flink读数据 addSource相关推荐

最新文章

热门文章