Flink核心技术与实战学习心得

Flink核心技术与实战学习心得

ApacheHive集成    

AsynchronousIO异步操作    

BroadcastState介绍与使用    

Catalog原理与使用    

Checkpoint监控与调优    

Checkpoint实现原理    

DataStream&DataSet与Table相互转换    

DataStreamAPI实践原理    

Dispatcher任务分发器    

FlinkClient实现原理    

FlinkRestAPI介绍与使用    

FlinkSQLTable数据类型    

FlinkTableAPISQL介绍与使用    

Flink类型系统    

Flink内存管理    

Flink内存配置与调优    

Flink时间概念    

JobGraph提交与运行（上）    

JoinWithDynamicTable    

JoinWithTemporalFunction    

JoinWithTemporalTables    

KeyedState介绍与使用    

Metric指标分类与采集    

NetworkStatck实现原理    

newtablesource&tablesinkapi    

obGraph提交与运行（下）    

OperatorState介绍与使用    

Pipeline与StreamGraph转换    

ProcessFunction应用    

QuerableState介绍与使用    

QueryingDynamicTables    

QueryWithTemporalCondition    

ResourceManager资源管理    

RPC通信机制    

Runtime整体架构    

Savepoint与Checkpoint    

SideOutput旁路输出    

SQLClient介绍与使用    

StateBackends状态管理器    

StateSchemaEvolution    

State序列化与反序列化    

TableAPISQL核心概念    

TableConnector介绍与使用    

TableConnector使用    

TableConnector注册与实现    

Task执行与调度    

Task重启和容错策略    

Watermark Generator    

Watermark Generator.hd    

WatermarkGenerator    

Watermark实践原理    

Watermark与Window的关系    

Window Assigner    

Window Evictors    

Window Trigger    

WindowAssigner    

WindowEvictors    

WindowFunction    

Windows窗口计算    

Windows多流合并    

WindowTrigger    

反压监控与原理    

分布式流处理模型    

项目实战：基于DataStreamAPI实现PV，UV统计    

项目实战：基于FlinkSQL实现Top10商品统计    

项目实战：实时交易反欺诈项目介绍    

项目实战：实时交易反欺诈项目演示    

有状态计算概念    

状态类型及应用    

自定义Connector    

自定义Function    

自定义SourceFunction