Ecosyste.ms: Repos

An open API service providing repository metadata for many open source software ecosystems.

GitHub / alonsoir / amazon-kinesis-data-analytics-java-examples

Example Java applications for Kinesis Data Analytics, demonstrating sources, sinks, and operators.

JSON API: https://repos.ecosyste.ms/api/v1/hosts/GitHub/repositories/alonsoir%2Famazon-kinesis-data-analytics-java-examples

Fork of aws-samples/amazon-kinesis-data-analytics-examples
Stars: 1
Forks: 0
Open Issues: 27

License: mit-0
Language:
Repo Size: 32.9 MB
Dependencies: 93

Created: almost 3 years ago
Updated: about 2 months ago
Last pushed: over 1 year ago
Last synced: about 2 months ago

Files

Loading...

Readme

Loading...

Dependencies

Beam/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.903 import
org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
com.fasterxml.jackson.module:jackson-module-jaxb-annotations 2.10.2
org.apache.beam:beam-runners-flink-${flink.version.minor} 2.23.0
org.apache.beam:beam-sdks-java-core 2.23.0
org.apache.beam:beam-sdks-java-io-amazon-web-services 2.23.0
org.apache.beam:beam-sdks-java-io-kinesis 2.23.0

CloudWatchSink/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.903 import
org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-flink 1.1.0
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
org.apache.flink:flink-connector-kinesis_2.12 ${flink.version}

CustomKeystore/pom.xml maven

org.apache.flink:flink-java ${flink.version} provided
org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-kinesisanalytics-flink 2.0.0
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
org.apache.flink:flink-connector-kafka_2.11 ${flink.version}

CustomMetrics/RecordCount/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.903 import
org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-flink 2.0.0
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
org.apache.flink:flink-connector-kinesis_2.12 ${flink.version}

CustomMetrics/WordCount/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.903 import
org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-flink 2.0.0
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
org.apache.flink:flink-connector-kinesis_2.12 ${flink.version}

EfoConsumer/pom.xml maven

org.apache.flink:flink-streaming-java_2.11 1.11.1 provided
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
software.amazon.kinesis:amazon-kinesis-connector-flink 2.0.0

FirehoseSink/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.903 import
org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-flink 2.0.0
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
org.apache.flink:flink-connector-kinesis_2.12 ${flink.version}

GettingStarted/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.903 import
org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-flink 2.0.0
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
org.apache.flink:flink-connector-kinesis_2.12 ${flink.version}

GettingStartedTable/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.903 import
org.apache.flink:flink-clients_2.12 1.11.1 provided
org.apache.flink:flink-s3-fs-hadoop 1.11.1 provided
org.apache.flink:flink-streaming-java_2.12 1.11.1 provided
org.apache.flink:flink-table-api-java-bridge_2.12 1.11.1 provided
org.apache.flink:flink-table-common 1.11.1 provided
org.apache.flink:flink-table-planner-blink_2.12 1.11.1 provided
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
com.google.code.gson:gson 2.8.5
org.apache.flink:flink-connector-kafka_2.12 1.11.1
org.apache.flink:flink-json 1.11.1
org.projectlombok:lombok 1.18.16

GettingStarted_1_6/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.379 import
org.apache.flink:flink-streaming-java_2.11 1.6.2 provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-flink 1.0.1
com.amazonaws:aws-kinesisanalytics-runtime 1.0.1
org.apache.flink:flink-connector-kinesis_2.11 1.6.2

GettingStarted_1_8/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.379 import
org.apache.flink:flink-streaming-java_2.11 ${flink.version} provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-flink 1.0.1
com.amazonaws:aws-kinesisanalytics-runtime 1.0.1
org.apache.flink:flink-connector-kinesis_2.11 ${flink.version}

KafkaConnectors/pom.xml maven

org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-kinesisanalytics-flink 2.0.0
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
org.apache.flink:flink-connector-kafka_2.11 ${flink.version}

S3Sink/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.903 import
org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-flink 2.0.0
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
org.apache.flink:flink-connector-kinesis_2.12 ${flink.version}

SlidingWindow/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.903 import
org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-flink 2.0.0
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
org.apache.flink:flink-connector-kinesis_2.12 ${flink.version}

TumblingWindow/pom.xml maven

com.amazonaws:aws-java-sdk-bom 1.11.903 import
org.apache.flink:flink-streaming-java_2.12 ${flink.version} provided
com.amazonaws:aws-java-sdk-logs
com.amazonaws:aws-kinesisanalytics-flink 2.0.0
com.amazonaws:aws-kinesisanalytics-runtime 1.2.0
org.apache.flink:flink-connector-kinesis_2.12 ${flink.version}