flink

flink copied to clipboard

Update nightly-trigger.yml

1

##base : [email protected] ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way...

aripitek

Enhance Javadoc documentation for WordCount Tokenizer class

2

Updates the Javadoc for the WordCount.Tokenizer class to provide a clear and structured explanation of its behavior. The new documentation outlines the purpose of the class, how the input is...

Diogo-Sardagna

Add input validation to WordCount Tokenizer for robustness

1

Introduces a defensive check at the beginning of the ‘flatMap’ method in the WordCount.Tokenizer class to ensure the input string is neither null nor blank. This change prevents unnecessary computation...

Diogo-Sardagna

Use isEmpty() instead of length() > 0 in WordCount Tokenizer

1

The change enhances code clarity by using the semantically appropriate method provided by the String API. Although functionally equivalent, ‘isEmpty()’ more clearly communicates the intent of checking for an empty...

Diogo-Sardagna

[Improvement] Storage Partition Join

2

## What is the purpose of the change Currently, Apache Flink's does not support storage partition join, which can lead to unnecessary data shuffles in batch mode. This PR implements...

tharvey5