Search results
Jump to navigation
Jump to search
- * **并行处理 (Parallel Processing):** 通过将数据和计算任务分解成多个子任务，并在多个� * **实时性 (Real-time Processing):** 能够对实时产生的数据进行快速处理和分析，为用户� ...9 KB (165 words) - 05:06, 14 April 2025
- * **流 (Stream):** 代表持续不断到达的事件序列。在 Kafka Streams 中，流� * **时间 (Time):** Kafka Streams 处理流数据时，需要考虑时间的概念。它支持三种时间类型：处理时间 (Processing Time)、事件时间 (Event Time) 和摄取时间 (Ingestion Time)。选择 ...10 KB (334 words) - 04:28, 6 May 2025
- * **流处理 (Stream Processing):** 在流处理应用中，需要考虑数据流的安全性和完整性� [[Category:软件架构安全]] ...10 KB (208 words) - 00:07, 15 May 2025
- * **DStream (Discretized Stream):** DStream 是 Spark Streaming 的核心抽象，它代表一个连续的 [[Category:流处理 (Category:Stream processing)]] ...10 KB (312 words) - 14:58, 11 May 2025
- * **CEP (Complex Event Processing):** [[复杂事件处理]]允许将多个事件组合成更有意义的事� DataStream<String> stream = env.addSource(new FlinkKafkaConsumer<>("my-topic", new SimpleStringSchema ...10 KB (245 words) - 02:09, 4 May 2025
- ...eams，一个用于构建流处理应用程序的库。它允许您使用简单的 API 对 Kafka 中的数据进行转换、聚合和过滤。了解 [[流处理 (Stream Processing)]] 是理解 Kafka Streams 的关键。 [[Category:Kafka (软件)]] ...10 KB (387 words) - 20:09, 30 April 2025
- * '''流处理 (Stream Processing):''' Kafka Streams, Apache Flink 等流处理框架可以用于实时处理 [[Category:金融科技 ...9 KB (326 words) - 16:02, 27 March 2025
