com.northconcepts.datapipeline.transform

Class FlattenRecord

java.lang.Object

com.northconcepts.datapipeline.transform.Transformer

com.northconcepts.datapipeline.transform.FlattenRecord

public class FlattenRecord
extends Transformer

Flattens an array field by creating one record for each value. See FieldPath for supported field name expressions.

Constructor Summary

Constructors

Constructor and Description
FlattenRecord()

Method Summary

Modifier and Type	Method and Description
DataException	addExceptionProperties(DataException exception)
String	getFieldSeparator()
FlattenRecord	setFieldSeparator(String fieldSeparator)
String	toString()
boolean	transform(Record record) Applies this transformer to a record on its way through a TransformingReader or TransformingWriter.

Methods inherited from class com.northconcepts.datapipeline.transform.Transformer

close, geEndpoint, getEndpoint, getReader, getWriter, of, open, setWriter

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FlattenRecord

public FlattenRecord()

Method Detail

getFieldSeparator

public String getFieldSeparator()

setFieldSeparator

public FlattenRecord setFieldSeparator(String fieldSeparator)

transform

public boolean transform(Record record)
                  throws Throwable

Description copied from class: Transformer

Applies this transformer to a record on its way through a TransformingReader or TransformingWriter.

Contract for subclasses (see also docs/authoring/Transformer.md):

• Mutate record in place as needed.
• Return true to keep the record in the pipeline.
• Return false to drop the record (the host routes it to a discard writer if one is configured, otherwise it disappears).
• Throw to fail (or route to a discard writer, depending on host configuration).
• Do not call incrementRecordCount() on the host endpoint; the host handles it.

Specified by:

transform in class Transformer

Throws:

Throwable

addExceptionProperties

public DataException addExceptionProperties(DataException exception)

Overrides:

addExceptionProperties in class Transformer

toString

public String toString()

Overrides:

toString in class Object