Package org.apache.flink.streaming.examples.dsv2.join

Class Join

  • public class Join
extends Object
    Example illustrating a join between two data streams. The example works on two input streams with pairs (name, grade) and (name, salary) respectively. It joins the streams based on "name".

    The example uses a built-in sample data as inputs, which can be found in the resources directory.

    Usage:

    • --output <path>The output directory where the Job will write the results. If no output path is provided, the Job will print the results to stdout .

    This example shows how to:

    • Usage of Join extension in DataStream API V2

    Please note that if you intend to run this example in an IDE, you must first add the following VM options: "--add-opens=java.base/java.util=ALL-UNNAMED". This is necessary because the module system in JDK 17+ restricts some reflection operations.

    Please note that the DataStream API V2 is a new set of APIs, to gradually replace the original DataStream API. It is currently in the experimental stage and is not fully available for production.