ForkEnrichment 프로세서
ForkEnrichment 프로세서
Openflow의 ForkEnrichment 프로세서는 JoinEnrichment 프로세서와 함께 사용되는 프로세서예요. 들어오는 FlowFile을 복제(clone)해 각각에 적절한 속성을 추가해준 뒤 원본과 복제본을 별도 관계로 보내, 이후 조인(join) 기반의 강화(enrichment) 작업이 가능하도록 준비해줘요.
출처: Snowflake 문서
본문
번들 (Bundle)
org.apache.nifi | nifi-standard-nar
설명 (Description)
JoinEnrichment 프로세서와 함께 사용되며, JoinEnrichment 프로세서가 기능을 수행하는 데 필요한 속성을 추가하는 역할을 해요. 들어오는 각 FlowFile은 복제돼요. 원본 FlowFile에는 적절한 속성이 추가된 뒤 'original' 관계로 보내지고, 복제본에는 적절한 속성이 추가된 뒤 'enrichment' 관계로 보내져요. 이 프로세서들이 어떻게 함께 동작하고, NiFi에서 이 프로세서들을 이용해 강화 작업을 수행하는 방법에 대한 자세한 내용은 JoinEnrichment 프로세서 문서(특히 Additional Details)를 참고해요.
태그 (Tags)
enrich, fork, join, record
입력 요구 사항 (Input Requirement)
필수 (REQUIRED)
민감 동적 속성 지원 (Supports Sensitive Dynamic Properties)
아니요 (false)
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| enrichment | 적절한 속성이 추가된 같은 입력 FlowFile의 복제본이 이 관계로 보내져요. |
| original | 적절한 속성이 추가된 입력 FlowFile이 이 관계로 보내져요. |
쓰기 속성 (Writes attributes)
| 이름 | 설명 |
|---|---|
| enrichment.group.id | 'original' FlowFile과 'enrichment' FlowFile을 상호 연관시키기 위해 사용하는 Group ID예요. |
| enrichment.role | 강화에 사용할 역할로, ORIGINAL 또는 ENRICHMENT 중 하나예요. |