com.northconcepts.datapipeline.transform

Class FastRenameField

java.lang.Object

com.northconcepts.datapipeline.transform.Transformer

com.northconcepts.datapipeline.transform.FastRenameField

public class FastRenameField
extends Transformer

An performant alternative to RenameField that assumes 1) a flat table structure (no nested fields or arrays), 2) columns are always in the same position from row to row 3) no missing fields (nulls field values are okay), and 4) the target name does not already exist (otherwise there will be two fields with the same name).

Constructor Summary

Constructors

Constructor and Description
FastRenameField(Integer oldIndex, String newName)
FastRenameField(String oldName, String newName)

Method Summary

Modifier and Type	Method and Description
String	getNewName()
Integer	getOldIndex()
String	getOldName()
protected void	open() Called by TransformingReader or TransformingWriter when their open() method is called (before reading or writing starts).
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, setWriter

Methods inherited from class java.lang.Object

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

Constructor Detail

FastRenameField

public FastRenameField(String oldName,
                       String newName)

FastRenameField

public FastRenameField(Integer oldIndex,
                       String newName)

Method Detail

getOldName

public String getOldName()

getOldIndex

public Integer getOldIndex()

getNewName

public String getNewName()

open

protected void open()

Description copied from class: Transformer

Called by TransformingReader or TransformingWriter when their open() method is called (before reading or writing starts).

Overrides:

open in class Transformer

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