ForkRecord 2025.5.31.15

번들

org.apache.nifi | nifi-standard-nar

설명

이 프로세서를 통해 사용자는 1개의 레코드를 여러 개의 레코드로 포크할 수 있습니다. 사용자는 RECORD 오브젝트를 포함하는 ARRAY 유형의 필드를 가리키는 1개 이상의 레코드 경로를 동적 속성으로 지정해야 합니다. 프로세서는 ‘분할’ 및 ‘추출’의 두 가지 모드를 허용합니다. 두 모드 모두 지정된 배열에 포함된 요소당 1개의 레코드가 생성됩니다. ‘분할’ 모드에서는 생성된 각 레코드가 입력된 것과 동일한 스키마를 유지하지만, 배열에는 1개의 요소만 포함됩니다. ‘추출’ 모드에서 배열의 요소는 레코드 유형이어야 하며 생성된 레코드가 됩니다. 또한 ‘추출’ 모드에서는 생성된 각 레코드가 루트 수준에서 추출된 레코드까지 상위 항목의 모든 필드를 포함할지 여부를 지정할 수 있습니다. 여기서는 레코드에 추가할 필드가 Record Writer 컨트롤러 서비스의 스키마에 정의되어 있다고 가정합니다. 이 프로세서의 추가 상세 설명서에 있는 예시를 참조하십시오.

태그

array, content, event, fork, record, stream

입력 요구 사항

REQUIRED

민감한 동적 속성 지원

false

속성

속성

설명

포크 모드

프로세서의 포크 모드를 지정합니다

포함-상위 항목 필드

이 매개 변수는’추출’모드에서만 유효합니다. true로 설정하면 루트 레벨부터 지정된 배열까지 모든 필드가 포크할 배열의 각 요소의 필드로 추가됩니다.

record-reader

수신 데이터를 읽는 데 사용할 컨트롤러 서비스를 지정합니다

record-writer

레코드 작성에 사용할 컨트롤러 서비스를 지정합니다

관계

이름

설명

실패

FlowFile 이 포크 작업 중에 오류를 생성하는 경우, 이 관계로 라우팅됩니다

포크

포크된 레코드가 포함된 FlowFiles 은 이 관계로 라우팅됩니다

원본

원본 FlowFiles 은 이 관계로 라우팅됩니다

Writes 특성

이름

설명

record.count

생성된 FlowFile 에는 FlowFile 에 기록된 레코드의 수를 나타내는 ‘record.count’ 특성이 있습니다.

mime.type

Record Writer가 나타내는 MIME 유형

<Record Writer의 특성>

구성된 Record Writer가 반환하는 모든 특성은 FlowFile 에 추가됩니다.