flink clickhouse sink
2022-04-06 02:53:50 26KB flink 大数据 big data
1
以flink处理kafka消息流场景为例,将接受到的kafka消息sink到mysql、elastic、hdfs、kafka,通过真实的案例,助你入门flink计算框架。课程案例代码也可移植到其它业务系统,实现快速开发。
1
hdfs sink相关hadoop jar包。亲测有效,请注意版本。也可根据错误日志自己去hadoop jar包里找。注意另外两个xml要放到flume conf目录下,这里只提供jar包。
2022-01-16 19:13:20 15.61MB 大数据 日志采集 flume hdfs
自己写的gstreamer MP3 sink 直接对mp3 数据流进行解码,使用ALSA播放。 对开发人员有如下借鉴意义: 1,如何写GStreamer sink 2,如何分析mp3数据 3,如何使用alsa
2021-11-08 21:58:16 800KB gstreamer mp3 sink
1
android端 wifi display sink端apk,需平台端支持一些接口,所以只是有些对原生android修改不大的手机可以使用。多试一些手机吧。网上找的,仅供大家学习使用。
2021-11-06 20:18:55 11.36MB wifi display miracast android
1
an5418-How to build a simple USB-PD sink application with STM32CubeMX
2021-10-13 14:02:49 11.05MB stm32 cubemx usb-pd
1
hdfs sink相关hadoop jar包。亲测有效,请注意版本。也可根据错误日志自己去hadoop jar包里找。注意另外两个xml要放到flume conf目录下,这里只提供jar包。
2021-08-25 09:53:48 15.61MB 大数据 日志采集 flume hdfs
1
CH224单芯片集成PD3.0/2.0,BC1.2等升压快充协议,内置PD通讯模块,高集成度,外围精简。支持 输出电压检测功能,并且提供过温、过压保护等。可广泛应用于各类电子设备拓展高功率输入,如无线 充电器、电动牙刷、锂电池电动工具等各类应用场合
2021-07-07 11:05:27 98KB PD3.0
1
使用spark集成flume,由于flume默认只支持pull消息的方式,不过它可以自定义消息拉取方式,现要使用poll方式,可以使用spark-streaming-flume-sink_2.11-2.1.0.jar包下的org.apache.spark.streaming.flume.sink.SparkSink
2021-06-14 23:11:30 85KB Spark flume
1
本文主要来介绍 Flink 读取 Kafka数据,并实时下沉(Sink)数据到 Redis 的过程。        通过如下链接:Flink官方文档,我们知道数据保存到 Redis 的容错机制是 at least once。所以我们通过幂等操作,使用新数据覆盖旧数据的方式,以此来实现 exactly-once 。 1.代码部分 1.1 config.properties配置文件 bootstrap.server=192.168.204.210:9092,192.168.204.211:9092,192.168.204.212:9092 group.id=testGroup auto.offse
2021-06-03 03:26:12 161KB ed edi flink
1