Apache Flink용 매니지드 서비스에 대한 Java 예제 - Managed Service for Apache Flink

Amazon Managed Service for Apache Flink는 이전에 Amazon Kinesis Data Analytics for Apache Flink로 알려졌습니다.

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

Apache Flink용 매니지드 서비스에 대한 Java 예제

다음 예제는 Java로 작성된 애플리케이션을 만드는 방법을 보여줍니다.

참고

대부분의 예제는 로컬, 사용자가 선택한 개발 시스템 및 Apache Flink용 Amazon Managed Service 모두에서 실행되도록 설계되었습니다. IDE 애플리케이션 파라미터를 전달하는 데 사용할 수 있는 메커니즘과 두 환경 모두에서 변경 없이 애플리케이션을 실행하도록 종속성을 올바르게 설정하는 방법을 보여줍니다.

이 예제에서는 를 사용하여 Kinesis 데이터 스트림에서 읽고 다른 Kinesis 데이터 스트림에 쓰는 간단한 애플리케이션을 보여줍니다. DataStream API 이 예제는 올바른 종속성을 사용하여 파일을 설정하고, uber-를 빌드한 다음 구성 매개 변수를 파싱하여 로컬JAR, 사용자 및 Apache Flink용 Amazon Managed Service 모두에서 애플리케이션을 실행할 수 있도록 하는 방법을 보여줍니다. IDE

코드 예제: GettingStarted

이 예제에서는 Table API 및 를 사용하는 간단한 애플리케이션을 보여줍니다SQL. 동일한 Java 응용 프로그램에서 DataStream API OR와 통합하는 방법을 보여 줍니다. Table API SQL 또한 외부 데이터 생성기가 필요 없이 DataGen 커넥터를 사용하여 Flink 애플리케이션 자체 내에서 임의의 테스트 데이터를 생성하는 방법도 보여줍니다.

전체 예제: GettingStartedTable

이 예제는 DataStream API 's를 사용하여 S3 버킷에 JSON 파일을 쓰는 FileSink 방법을 보여줍니다.

코드 예제: S3Sink

이 예제에서는 표준 소비자 EFO 또는 를 사용하여 Kinesis 데이터 스트림의 소스 소비를 구성하는 방법과 Kinesis 데이터 스트림에 싱크를 설정하는 방법을 보여줍니다.

코드 예제: KinesisConnectors

이 예제는 Amazon Data Firehose (이전에는 Kinesis Data Firehose로 알려짐) 로 데이터를 보내는 방법을 보여줍니다.

코드 예제: KinesisFirehoseSink

이 예제에서는 에서 사용하는 네 가지 유형의 윈도우 집계를 보여줍니다. DataStream API

  1. 처리 시간에 따른 슬라이딩 윈도우

  2. 이벤트 시간에 따른 슬라이딩 윈도우

  3. 처리 시간에 따른 텀블링 윈도우

  4. 이벤트 시간에 따른 텀블링 윈도우

코드 예제: 윈도잉

이 예제에서는 사용자 지정 지표를 Flink 애플리케이션에 추가하고 이를 지표로 CloudWatch 보내는 방법을 보여줍니다.

코드 예제: CustomMetrics