Class IterateExample


  • public class IterateExample
    extends Object
    Example illustrating iterations in Flink streaming.

    The program sums up random numbers and counts additions it performs to reach a specific threshold in an iterative streaming fashion.

    This example shows how to use:

    • streaming iterations,
    • buffer timeout to enhance latency,
    • directed outputs.
    • Constructor Detail

      • IterateExample

        public IterateExample()