JoinEnrichment 2025.5.31.15¶

번들¶

org.apache.nifi | nifi-standard-nar

설명¶

서로 다른 2개의 FlowFiles 에서 레코드를 결합하는 것으로, 1개의 FlowFile 인 ‘원본’에는 임의의 레코드가 포함되어 있고 두 번째 FlowFile 인 ‘보강’에는 첫 번째를 보강하는 데 사용해야 하는 추가 데이터가 포함되어 있습니다. 이 프로세서를 구성하는 방법과 이를 통해 달성하고자 하는 다양한 사용 사례에 대한 자세한 내용은 추가 세부 정보를 참조하십시오.

태그¶

combine, enrichment, fork, join, merge, record, recordpath, sql, streams, wrap

입력 요구 사항¶

REQUIRED

민감한 동적 속성 지원¶

false

속성¶

속성	설명
보강 Record Reader	‘보강’ FlowFile 을 읽는 Record Reader
삽입 레코드 경로	‘원본’ 레코드에서 ‘보강’ 레코드의 필드를 삽입할 위치를 지정합니다. RecordPath 가 원본 레코드의 기존 필드를 가리키지 않으면 보강이 삽입되지 않는다는 점에 유의하십시오.
Join Strategy	FlowFiles2개를 하나로 결합하는 방법을 지정합니다FlowFile
최대 보관함 수	한 번에 메모리에 보관할 수 있는 최대 빈 수를 지정합니다
원본 Record Reader	‘원본’ FlowFile 을 읽기 위한 Record Reader
Record Writer	결과 작성에 사용할 Record Writer입니다. Record Writer가 레코드로부터 스키마를 상속하도록 구성된 경우 상속할 스키마는 ‘원본’ 레코드 스키마와 ‘보강’ 레코드 스키마를 모두 병합한 결과가 됩니다.
SQL	평가할 SQL SELECT 문입니다. 식 언어를 제공할 수 있지만 그렇게 하면 성능이 저하될 수 있습니다. 이 프로세서는 한 번에 2개의 FlowFiles 을 처리하므로 특성이 참조되는 방식을 이해하는 것도 중요합니다. FlowFiles 에 모두 이름이 같지만 값이 다른 특성이 있는 경우 표현식 언어는 ‘보강’ FlowFile 에서 제공하는 값으로 해결됩니다.
Timeout	첫 번째 FlowFile 이 프로세서에 도착하면 두 번째 FlowFile 이 ‘시간 제한’ 관계로 라우팅될 때까지 기다릴 최대 시간을 지정합니다.
dbf-default-precision	DECIMAL/NUMBER 값이 ‘소수점’ Avro 논리 유형으로 작성된 경우 사용할 수 있는 자릿수를 나타내는 특정 ‘전체 자릿수’가 필요합니다. 일반적으로 전체 자릿수는 열 데이터 타입 정의 또는 데이터베이스 엔진 기본값에 의해 정의됩니다. 그러나 일부 데이터베이스 엔진에서는 정의되지 않은 전체 자릿수(0)가 반환될 수 있습니다. ‘Default Decimal Precision’은 정의되지 않은 전체 자릿수 숫자를 쓸 때 사용됩니다.
dbf-default-scale	DECIMAL/NUMBER 값을 ‘소수점’ Avro 논리 유형으로 작성하는 경우 가용성 있는 소수점 자릿수를 나타내는 특정 ‘스케일’이 필요합니다. 일반적으로 스케일은 열 데이터 타입 정의 또는 데이터베이스 엔진 기본값에 의해 정의됩니다. 그러나 정의되지 않은 전체 자릿수(0)가 반환되면 일부 데이터베이스 엔진에서는 스케일이 불확실할 수도 있습니다. 정의되지 않은 숫자를 쓸 때는 ‘Default Decimal Scale’이 사용됩니다. 값이 지정된 스케일보다 소수점이 많은 경우 값이 반올림됩니다(예: 1.53은 스케일 0으로 2가 되고 1.5는 스케일 1로 1.5가 됩니다).

관계¶

이름	설명
실패	‘원본’ 및 ‘강화’ FlowFiles 모두 프로세서에 도착했지만 레코드 결합에 실패한 경우, 이러한 두 FlowFiles 모두 이 관계로 라우팅됩니다.
joined	원본 및 보강 FlowFile 에서 레코드가 결합된 결과 FlowFiles 은 이 관계로 라우팅됩니다.
원본	수신 FlowFiles (‘원본’ 및 ‘보강’)은 모두 이 관계로 라우팅됩니다. 즉, 이는 이러한 FlowFiles 의 ‘원본’ 버전입니다.
시간 제한	수신 FlowFiles 중 하나(즉, ‘원본’ FlowFile 또는 ‘보강’ FlowFile)가 이 프로세서에 도착하지만 다른 하나가 구성된 시간 제한 기간 내에 도착하지 않으면, 도착한 FlowFile 이 이 관계로 라우팅됩니다.

Writes 특성¶

이름	설명
mime.type	Mime.type 특성을 Record Writer가 지정한 MIME 유형으로 설정합니다
record.count	FlowFile 에 있는 레코드의 수

참고 항목¶

org.apache.nifi.processors.standard.ForkEnrichment