com.northconcepts.datapipeline.transform

Class SelectFields

java.lang.Object

com.northconcepts.datapipeline.transform.Transformer

com.northconcepts.datapipeline.transform.SelectFields

Direct Known Subclasses:

IncludeFields

public class SelectFields
extends Transformer

Select and arrange fields according to the supplied field names -- like an SQL SELECT statement. See FieldPath for supported field name expressions.

Constructor Summary

Constructors

Constructor and Description
SelectFields(Collection<String> fieldNames)
SelectFields(String... fieldNames)

Method Summary

Modifier and Type	Method and Description
SelectFields	add(Collection<String> fieldNames)
SelectFields	add(String... fieldNames)
FieldList	getFields()
boolean	isLenient()
SelectFields	setLenient(boolean lenient)
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

addExceptionProperties, 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

SelectFields

public SelectFields(Collection<String> fieldNames)

SelectFields

public SelectFields(String... fieldNames)

Method Detail

isLenient

public boolean isLenient()

setLenient

public SelectFields setLenient(boolean lenient)

getFields

public FieldList getFields()

add

public SelectFields add(Collection<String> fieldNames)

add

public SelectFields add(String... fieldNames)

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

toString

public String toString()

Overrides:

toString in class Object