Pinned Repositories
amazon-kinesis-analytics-beam-taxi-consumer
Sample Apache Beam pipeline that can be deployed to Kinesis Data Analytics for Java Applications. It reads taxi events from a Kinesis data stream, processes and aggregates them, and ingests the result to Amazon CloudWatch for visualization.
amazon-kinesis-data-analytics-flinktableapi
A walkthrough of setting up a Kinesis Data Analytics for Java Application which ingest streaming JSON data and leverages the Flink Table API.
community
This repository holds the content submitted to https://cloud.google.com/community. Files added to the tutorials/ will appear at https://cloud.google.com/community/tutorials.
flink
Apache Flink
flink-lab-stuff
kda-flink-autoscaling
kda-flink-custom-keystore
Sample code to demonstrate use of custom truststore from KDA/Flink
kda-token-refresh1
Sample app to illustrate how to use Flink broadcast state to fetch and pass tokens downstream
keystore-conversion
HOWTO: Perform Java keystore conversion from PKCS12 to JKS
zep-flink-on-aws
karthitect's Repositories
karthitect/kda-flink-custom-keystore
Sample code to demonstrate use of custom truststore from KDA/Flink
karthitect/amazon-kinesis-data-analytics-flinktableapi
A walkthrough of setting up a Kinesis Data Analytics for Java Application which ingest streaming JSON data and leverages the Flink Table API.
karthitect/keystore-conversion
HOWTO: Perform Java keystore conversion from PKCS12 to JKS
karthitect/zep-flink-on-aws
karthitect/amazon-kinesis-analytics-beam-taxi-consumer
Sample Apache Beam pipeline that can be deployed to Kinesis Data Analytics for Java Applications. It reads taxi events from a Kinesis data stream, processes and aggregates them, and ingests the result to Amazon CloudWatch for visualization.
karthitect/community
This repository holds the content submitted to https://cloud.google.com/community. Files added to the tutorials/ will appear at https://cloud.google.com/community/tutorials.
karthitect/flink
Apache Flink
karthitect/flink-lab-stuff
karthitect/kda-flink-autoscaling
karthitect/kda-token-refresh1
Sample app to illustrate how to use Flink broadcast state to fetch and pass tokens downstream
karthitect/streaming-analytics-workshop
Learn how to build an end-to-end streaming architecture to ingest, analyze, and visualize streaming data in near real-time