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–2023 The Apache Software Foundation. All rights reserved.