108장. Apache Flink 구성 요소
Camel 버전 2.18로 사용 가능
이 문서에서는 Apache Camel의 Apache Flink 구성 요소에 대해 설명합니다. camel-flink 구성 요소는 Camel 커넥터와 Flink 작업 간에 브릿지를 제공합니다.
이 Camel Flink 커넥터는 다양한 전송에서 메시지를 라우팅하고 실행할 flink 작업을 동적으로 선택하고 들어오는 메시지를 작업에 대한 입력 데이터로 사용하고 마지막으로 결과를 Camel 파이프라인에 다시 전달하는 방법을 제공합니다.
Maven 사용자는 이 구성 요소에 대해 pom.xml 에 다음 종속성을 추가해야 합니다.
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-flink</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel core version -->
</dependency>108.1. URI 형식
현재 Flink 구성 요소는 Producers만 지원합니다. one can create Cryostat, DataStream 작업을 생성할 수 있습니다.
flink:dataset?dataset=#myDataSet&dataSetCallback=#dataSetCallback flink:datastream?datastream=#myDataStream&dataStreamCallback=#dataStreamCallback
FlinkEndpoint Options
Apache Flink 끝점은 URI 구문을 사용하여 구성됩니다.
flink:endpointType
다음 경로 및 쿼리 매개변수를 사용합니다.
108.1.1. 경로 매개변수(1 매개변수):
| 이름 | 설명 | 기본 | 유형 |
|---|---|---|---|
| endpointType | 끝점의 필수 유형(데이터 세트, 데이터 스트림). | EndpointType |
108.1.2. 쿼리 매개변수 (6 매개변수):
| 이름 | 설명 | 기본 | 유형 |
|---|---|---|---|
| 수집 (producer) | 결과를 수집하거나 계산해야 하는지 여부를 나타냅니다. | true | boolean |
| 데이터 세트 (producer) | 계산할 데이터 세트입니다. | DataSet | |
| dataSetCallback (producer) | Cryostat에 대해 작업을 수행하는 함수입니다. | DataSetCallback | |
| 데이터 스트림 (producer) | 계산할 데이터 스트림입니다. | DataStream | |
| dataStreamCallback (producer) | DataStream에 대해 작업을 수행하는 함수입니다. | DataStreamCallback | |
| 동기 (고급) | 동기 처리를 엄격하게 사용해야 하는지 또는 Camel이 비동기 처리를 사용할 수 있는지 여부를 설정합니다(지원되는 경우). | false | boolean |
