文件名称：Credit漫谈-svpwm的调制及谐波分析
文件大小：4.81MB
文件格式：PDF
更新时间：2024-07-10 12:54:39
flink
3.3 TaskManager执行task 3.3.1 TaskManager的基本组件 3.3.2 TaskManager执行Task 3.3.2.1 生成Task对象 3.3.2.2 运行Task对象 3.3.2.3 StreamTask的执行逻辑 3.4 StreamTask与StreamOperator 4. StreamOperator的抽象与实现 4.1 数据源的逻辑——StreamSource与时间模型 4.2 从数据输入到数据处理——OneInputStreamOperator & AbstractUdfStreamOperator 4.3 StreamSink 4.4 其他算子 5. 为执行保驾护航——Fault Tolerant与保证Exactly-Once语义 5.1 Fault Tolerant演进之路 5.1.1 Storm的Record acknowledgement模式 5.1.2 Spark streaming的micro batch模式 5.1.3 Google Cloud Dataflow的事务式模型 5.1.4 Flink的分布式快照机制 5.2 checkpoint的生命周期 5.2.1 触发checkpoint 5.2.2 Task层面checkpoint的准备工作 5.2.3 操作符的状态保存及barrier传递 5.3 承载checkpoint数据的抽象：State & StateBackend 6.数据流转——Flink的数据抽象及数据交换过程 6.1 flink的数据抽象 6.1.1 MemorySegment 6.1.2 ByteBuffer与NetworkBufferPool 6.1.3 RecordWriter与Record 6.2 数据流转过程 6.2.1 整体过程 6.2.2 数据跨task传递 6.3 Credit漫谈