BestHub
Sign in
Tagged articles
4 articles
Page 1 of 1
Wukong Talks Architecture
Wukong Talks Architecture
Jul 29, 2024 · Backend Development

Understanding the Java Stream Pipeline: Implementation Principles and Execution Process

This article explains the internal workings of Java's Stream API pipeline, covering how intermediate and terminal operations are recorded, combined, and executed via stages and Sink interfaces, illustrating lazy evaluation, stateful vs stateless operations, and the mechanisms behind parallel and sequential processing.

Intermediate OperationsJavaLazy Evaluation
0 likes · 21 min read
Understanding the Java Stream Pipeline: Implementation Principles and Execution Process
Big Data Technology & Architecture
Big Data Technology & Architecture
Apr 5, 2022 · Big Data

Using ElasticsearchSink with Apache Flink: Configuration, Retry Strategies, and Failure Handling

This article introduces the ElasticsearchSink for Apache Flink, explains how to add Maven dependencies, implement the sink with configuration and retry settings, details failure handlers, and highlights important considerations such as exception handling and checkpoint requirements for reliable streaming pipelines.

Big DataElasticsearchFailure Handling
0 likes · 9 min read
Using ElasticsearchSink with Apache Flink: Configuration, Retry Strategies, and Failure Handling