文件名称：java8stream源码-flink_local:flink的局部改进
文件大小：14.35MB
文件格式：ZIP
更新时间：2024-06-24 11:09:06
系统开源
java8流源码Apache Flink Apache Flink 是一个开源的流处理框架，具有强大的流处理和批处理能力。 了解更多关于 Flink 的信息 特征 支持批处理和数据流程序的流优先运行时 Java 和 Scala 中优雅流畅的 API 同时支持非常高的吞吐量和低事件延迟的运行时 基于Dataflow 模型，支持 DataStream API 中的事件时间和乱序处理 跨不同时间语义（事件时间、处理时间）的灵活窗口（时间、计数、会话、自定义触发器） 具有完全一次处理保证的容错 流媒体程序中的自然背压 图处理（批处理）、机器学习（批处理）和复杂事件处理（流）库 数据集（批处理）API 中对迭代程序 (BSP) 的内置支持 自定义内存管理，可在内存和核外数据处理算法之间进行高效、稳健的切换 Apache Hadoop MapReduce 和 Apache Storm 的兼容层 与 YARN、HDFS、HBase 和 Apache Hadoop 生态系统的其他组件集成 流媒体示例 case class WordWithCount ( word : String , count :