Reverted the PeriodicPerPartitionLoadEnrichmentData.java back to commit df1ea1608262d672cf5ee909fa2d62beb0e0724d as Flink does timer coalescing, so only one timer would be registered per key and per timestamp. the timestamp is rounded to every minute
Added Disclaimer for using S3 Select.
Removed code for which the pattern is removed from the blog.
Parameterised kinesis stream, S3 bucket and region using config.properties file.
By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.
Issue #, if available:
Description of changes:
Reverted the PeriodicPerPartitionLoadEnrichmentData.java back to commit df1ea1608262d672cf5ee909fa2d62beb0e0724d as Flink does timer coalescing, so only one timer would be registered per key and per timestamp. the timestamp is rounded to every minute
Added Disclaimer for using S3 Select.
Removed code for which the pattern is removed from the blog.
Parameterised kinesis stream, S3 bucket and region using
config.propertiesfile.By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.