public class KinesisExample extends Object
KafkaEvent
, group by some key, and finally
perform a rolling addition on each key for which the results are written back to another topic.
This example also demonstrates using a watermark assigner to generate per-partition watermarks directly in the Flink Kinesis consumer. For demonstration purposes, it is assumed that the String messages formatted as a (word,frequency,timestamp) tuple.
Example usage: --input-stream test-input --output-stream test-output --aws.endpoint https://localhost:4567 --flink.stream.initpos TRIM_HORIZON
Constructor and Description |
---|
KinesisExample() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.