Types & classes — github.com/coderblack/doit30

hub / github.com/coderblack/doit30_flink / types & classes

Types & classes167 in github.com/coderblack/doit30_flink

⨍ Functions 478◇ Types & classes 167

Base class for per-window {@link KeyedStateStore KeyedStateStores}. Used to allow per-window state access for {@link org.apache.flink.streaming.api.fu

flink_course/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java:691

ClassAbstractStreamOperator

Base class for all stream operators. Operators that contain a user function should extend the class {@link AbstractUdfStreamOperator} instead (which i

flink_course/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java:87

ClassActionLogAutoGen

@author 涛哥 @nick_name "deep as the sea" @contact qq:657270652 wx:doit_edu @site www.doitedu.cn @date 2021-03-27 @desc 行为日志生成模拟器（自动连续生成） <p> { "account

datagen/src/main/java/cn/doitedu/ActionLogAutoGen.java:55

ClassActionLogGenOne

@author hunter.d @qq 657270652 @wx haitao-duan @date 2021/4/5 运行一次，生成一条行为日志

datagen/src/main/java/cn/doitedu/ActionLogGenOne.java:21

ClassAdminClientDemo

kafka_course/src/main/java/cn/doitedu/kafka/AdminClientDemo.java:11

ClassBean1

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo12_JdbcConnectorTest2.java:65

ClassBean1

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo13_FileSystemConnectorTest.java:66

ClassBean1

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo11_UpsertKafkaConnectorTest2.java:72

ClassBean1

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo11_UpsertKafkaConnectorTest.java:64

ClassBean2

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo12_JdbcConnectorTest2.java:74

ClassBean2

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo13_FileSystemConnectorTest.java:75

ClassBean2

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo11_UpsertKafkaConnectorTest2.java:81

ClassBid

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo16_TimeWindowDemo.java:140

ClassBoundedOutOfOrdernessWatermarks

A WatermarkGenerator for situations where records are out of order, but you can place an upper bound on how far the events are out of order. An out-of

flink_course/src/main/java/org/apache/flink/api/common/eventtime/BoundedOutOfOrdernessWatermarks.java:36

InterfaceCollector

datagen/src/main/java/cn/doitedu/module/Collector.java:3

ClassCollectorConsoleImpl

datagen/src/main/java/cn/doitedu/module/CollectorConsoleImpl.java:3

ClassCollectorKafkaImpl

datagen/src/main/java/cn/doitedu/module/CollectorKafkaImpl.java:8

ClassConsumeRunnable

消费拉取数据的线程runnable

kafka_course/src/main/java/cn/doitedu/kafka/Kafka编程练习_消费者.java:40

ClassConsumeRunnableBitmap

消费拉取数据的线程runnable

kafka_course/src/main/java/cn/doitedu/kafka/Kafka编程练习_消费者_Bitmap.java:40

ClassConsumeRunnableBloomFilter

消费拉取数据的线程runnable

kafka_course/src/main/java/cn/doitedu/kafka/Kafka编程练习_消费者_判重.java:29

ClassConsumerDemo

kafka_course/src/main/java/cn/doitedu/kafka/ConsumerDemo.java:15

ClassConsumerDemo2

手动指定消费起始偏移量位置

kafka_course/src/main/java/cn/doitedu/kafka/ConsumerDemo2.java:18

ClassConsumerDemo3

消费组再均衡观察

kafka_course/src/main/java/cn/doitedu/kafka/ConsumerDemo3.java:16

ClassConsumer实现ExactlyOnce手段1

利用mysql的事务机制，来实现kafka consumer数据传输过程端到端的 exactly - once <p> 准备工作： 1. 创建topic [root@doit01 ~]# kafka-topics.sh --create --topic user-info --partition

kafka_course/src/main/java/cn/doitedu/kafka/Consumer实现ExactlyOnce手段1.java:36

ClassContext

{@code Context} is a utility for handling {@code Trigger} invocations. It can be reused by setting the {@code key} and {@code window} fields. No inter

flink_course/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java:826

ClassDemo10_KafkaConnectorDetail

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/12 @Desc: 学大数据，到多易教育流 ===> 表，过程中如何传承事件时间和 wat

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo10_KafkaConnectorDetail.java:19

ClassDemo11_UpsertKafkaConnectorTest

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo11_UpsertKafkaConnectorTest.java:14

ClassDemo11_UpsertKafkaConnectorTest2

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo11_UpsertKafkaConnectorTest2.java:14

ClassDemo12_JdbcConnectorTest1

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo12_JdbcConnectorTest1.java:9

ClassDemo12_JdbcConnectorTest2

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo12_JdbcConnectorTest2.java:13

ClassDemo13_FileSystemConnectorTest

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo13_FileSystemConnectorTest.java:15

ClassDemo14_MysqlCdcConnector

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/13 @Desc: 学大数据，到多易教育 mysql的cdc连接器使用测试

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo14_MysqlCdcConnector.java:15

ClassDemo14_StreamFromToTable

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/13 @Desc: 学大数据，到多易教育 mysql的cdc连接器使用测试

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo14_StreamFromToTable.java:23

ClassDemo16_TimeWindowDemo

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/13 @Desc: 学大数据，到多易教育 mysql的cdc连接器使用测试

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo16_TimeWindowDemo.java:24

ClassDemo17_TimeWindowJoin

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/16 @Desc: 学大数据，到多易教育各种窗口JOIN的代码示例

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo17_TimeWindowJoin.java:21

ClassDemo18_IntervalJoin

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/16 @Desc: 学大数据，到多易教育常规join示例常规join的底层实现，是通过在用状态来

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo18_IntervalJoin.java:23

ClassDemo18_RegularJoin

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo18_RegularJoin.java:23

ClassDemo19_ArrayJoin

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo19_ArrayJoin.java:12

ClassDemo19_LookupJoin

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/16 @Desc: 学大数据，到多易教育常规join示例常规join的底层实现，是通过在用状态来缓存两表数

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo19_LookupJoin.java:22

ClassDemo1_TableSql

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo1_TableSql.java:16

ClassDemo20_Temporal_Join

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/16 @Desc: 学大数据，到多易教育时态join代码示例

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo20_Temporal_Join.java:23

ClassDemo21_CustomScalarFunction

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo21_CustomScalarFunction.java:11

ClassDemo22_CustomAggregateFunction

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/16 @Desc: 学大数据，到多易教育自定义聚合函数

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo22_CustomAggregateFunction.java:18

ClassDemo23_TableFunction

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo23_TableFunction.java:10

ClassDemo24_TableAggregateFunction

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/17 @Desc: 学大数据，到多易教育自定义表聚合函数示例什么叫做表聚合函数： 1,male,zs,88

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo24_TableAggregateFunction.java:59

ClassDemo24_TableAggregateFunction2

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo24_TableAggregateFunction2.java:62

ClassDemo25_MetricDemos

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo25_MetricDemos.java:12

ClassDemo2_TableApi

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo2_TableApi.java:10

ClassDemo3_TableObjectCreate

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/12 @Desc: 学大数据，到多易教育 Table对象创建方式示例代码

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo3_TableObjectCreate.java:34

ClassDemo4_SqlTableCreate

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/12 @Desc: 学大数据，到多易教育表创建方式示例：带sql表名称的

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo4_SqlTableCreate.java:27

ClassDemo5_CatalogDemo

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/12 @Desc: 学大数据，到多易教育 hive元数据空间 catalog 原理测试

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo5_CatalogDemo.java:17

ClassDemo6_Exercise

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/12 @Desc: 学大数据，到多易教育 >>>>> 练习题需求 >>>>>>> 基本： kafka中

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo6_Exercise.java:30

ClassDemo7_ColumnDetail1_Sql

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/11 @Desc: schema定义详细示例（sql DDL语句定义表结构）

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo7_ColumnDetail1_Sql.java:13

ClassDemo7_ColumnDetail2_TableApi

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/11 @Desc: schema定义详细示例（tableApi方式定义表结构）

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo7_ColumnDetail2_TableApi.java:14

ClassDemo8_CsvFormat

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/12 @Desc: 学大数据，到多易教育 csv format详解

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo8_CsvFormat.java:18

ClassDemo8_JsonFormat

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/12 @Desc: 学大数据，到多易教育 json format详解

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo8_JsonFormat.java:18

ClassDemo9_EventTimeAndWatermark

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/12 @Desc: 学大数据，到多易教育 watermark 在DDL中的定义示例代码

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo9_EventTimeAndWatermark.java:30

ClassDemo9_EventTimeAndWatermark2

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/12 @Desc: 学大数据，到多易教育流 ===> 表，过程中如何传承事件时间和

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo9_EventTimeAndWatermark2.java:32

ClassDemo9_EventTimeAndWatermark3

@Author: deep as the sea @Site: <a href="www.51doit.com">多易教育</a> @QQ: 657270652 @Date: 2022/6/12 @Desc: 学大数据，到多易教育流 ===> 表，过程中如何传承事件时间和

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo9_EventTimeAndWatermark3.java:30

ClassEvent

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo9_EventTimeAndWatermark2.java:103

ClassEventBean

flink_course/src/main/java/cn/doitedu/flink/java/demos/_19_WaterMark_Api_Demo.java:117

ClassEventBean

flink_course/src/main/java/cn/doitedu/flinksql/fuxi/EventBean.java:9

ClassEventBean2

flink_course/src/main/java/cn/doitedu/flink/java/demos/EventBean2.java:7

ClassEventCount

flink_course/src/main/java/cn/doitedu/flink/exercise/EventCount.java:5

ClassEventLog

flink_course/src/main/java/cn/doitedu/flink/java/demos/EventLog.java:8

ClassEventUserInfo

flink_course/src/main/java/cn/doitedu/flink/exercise/EventUserInfo.java:5

ClassExercise

flink_course/src/main/java/cn/doitedu/flinksql/fuxi/Exercise.java:43

ClassExercise_1

@Author: deep as the sea @Site: www.51doit.com @QQ: 657270652 @Date: 2022/4/28 @Desc: 创建两个流流1 ： “id,eventId,cnt” 1,event01,3 1,event02,2 2,event02,4

flink_course/src/main/java/cn/doitedu/flink/exercise/Exercise_1.java:63

ClassFlinkKafkaDemo

flink_course/src/main/java/tmp/FlinkKafkaDemo.java:52

ClassFriendInfo

flink_course/src/main/java/cn/doitedu/flink/java/demos/_07_Transformation_Demos.java:184

ClassHsetInsertMapper

HASH结构数据插入

flink_course/src/main/java/cn/doitedu/flink/java/demos/_12_RedisSinkOperator_Demo1.java:83

ClassKafka编程练习

创建一个topic [root@doit01 ~]# kafka-topics.sh --create --topic doit30-events --partitions 3 --replication-factor 2 --zookeeper doit01:2181 可以用命令去监视这个top

kafka_course/src/main/java/cn/doitedu/kafka/Kafka编程练习.java:48

ClassKafka编程练习_消费者

kafka_course/src/main/java/cn/doitedu/kafka/Kafka编程练习_消费者.java:17

ClassKafka编程练习_消费者_Bitmap

kafka_course/src/main/java/cn/doitedu/kafka/Kafka编程练习_消费者_Bitmap.java:16

ClassKafka编程练习_消费者_判重

kafka_course/src/main/java/cn/doitedu/kafka/Kafka编程练习_消费者_判重.java:17

ClassKafka自身事务机制

从kafka的topic-a中读数据，处理（把读到的数据转大写），处理结果写回kafka的topic-b 利用kafka自身的事务机制，来实现端到端的eos语义核心点：让消费端的偏移量记录更新和生产端的数据落地，绑定在一个事务中

kafka_course/src/main/java/cn/doitedu/kafka/Kafka自身事务机制.java:19

ClassKeyedStateDemo

flink_course/src/main/java/cn/doitedu/flinksql/fuxi/KeyedStateDemo.java:26

ClassLogBean

datagen/src/main/java/cn/doitedu/module/LogBean.java:7

ClassLogBeanWrapper

datagen/src/main/java/cn/doitedu/module/LogBeanWrapper.java:7

ClassLogRunnable

datagen/src/main/java/cn/doitedu/module/LogRunnable.java:11

ClassMapper1

flink_course/src/main/java/cn/doitedu/flink/task/Mapper1.java:3

ClassMapper2

flink_course/src/main/java/cn/doitedu/flink/task/Mapper2.java:3

ClassMergingWindowStateStore

Special {@link AbstractPerWindowStateStore} that doesn't allow access to per-window state.

flink_course/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java:706

ClassMyAccumulator

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo22_CustomAggregateFunction.java:45

ClassMyAccumulator

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo24_TableAggregateFunction.java:86

ClassMyAccumulator

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo24_TableAggregateFunction2.java:89

ClassMyAvg

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo22_CustomAggregateFunction.java:50

ClassMyBieniuProcessFuntion

利用算子状态做wordcount

flink_course/src/main/java/cn/doitedu/flinksql/fuxi/KeyedStateDemo.java:73

ClassMyDataGen

业务数据生成器

kafka_course/src/main/java/cn/doitedu/kafka/Kafka编程练习.java:60

ClassMyEventTimeTrigger

flink_course/src/main/java/cn/doitedu/flink/java/demos/_21_Window_Api_Demo4.java:100

ClassMyFlatMapFunction

flink_course/src/main/java/cn/doitedu/flink/java/demos/_02_BatchWordCount.java:35

ClassMyGuage

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo25_MetricDemos.java:52

ClassMyParallelSourceFunction

flink_course/src/main/java/cn/doitedu/flink/java/demos/_06_CustomSourceFunction.java:84

ClassMyPartitioner

kafka_course/src/main/java/cn/doitedu/kafka/MyPartitioner.java:8

ClassMyRichParallelSourceFunction

flink_course/src/main/java/cn/doitedu/flink/java/demos/_06_CustomSourceFunction.java:166

ClassMyRichSourceFunction

flink_course/src/main/java/cn/doitedu/flink/java/demos/_06_CustomSourceFunction.java:98

ClassMySourceFunction

flink_course/src/main/java/cn/doitedu/flink/java/demos/_06_CustomSourceFunction.java:50

ClassMySplit

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo23_TableFunction.java:50

ClassMySplit

flink_course/src/main/java/cn/doitedu/flinksql/demos/Demo19_ArrayJoin.java:37

ClassMyTimeEvictor

flink_course/src/main/java/cn/doitedu/flink/java/demos/_21_Window_Api_Demo4.java:167

next →1–100 of 167, ranked by callers