107장. 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>107.1. URI 형식
현재 Flink Component는 Producers만 지원합니다. DataSet, DataStream 작업을 만들 수 있습니다.
flink:dataset?dataset=#myDataSet&dataSetCallback=#dataSetCallback flink:datastream?datastream=#myDataStream&dataStreamCallback=#dataStreamCallback
FlinkEndpoint 옵션
Apache Flink 엔드포인트는 URI 구문을 사용하여 구성됩니다.
flink:endpointType
다음 경로 및 쿼리 매개변수를 사용합니다.
107.1.1. 경로 매개 변수 (1 매개변수):
| 이름 | 설명 | 기본값 | 유형 |
|---|---|---|---|
| endpointType | 끝점의 필수 유형(데이터 세트, 데이터 스트림). | EndpointType |
107.1.2. 쿼리 매개변수(6 매개변수):
| 이름 | 설명 | 기본값 | 유형 |
|---|---|---|---|
| 수집 (producer) | 결과를 수집하거나 계산해야 하는지 여부를 나타냅니다. | true | boolean |
| 데이터 세트 (producer) | 계산할 데이터 집합입니다. | DataSet | |
| dataSetCallback (producer) | DataSet에 대한 작업을 수행합니다. | DataSetCallback | |
| datastream (producer) | 계산할 데이터 스트림입니다. | DataStream | |
| dataStreamCallback (producer) | DataStream에 대한 작업 수행. | DataStreamCallback | |
| synchronous (advanced) | 동기 처리를 엄격하게 사용해야 하는지 또는 Camel이 비동기 처리를 사용할 수 있는지 여부를 설정합니다(지원되는 경우). | false | boolean |
