com.northconcepts.datapipeline.transform

Class SetBatchSequenceNumberField

java.lang.Object

com.northconcepts.datapipeline.transform.Transformer

com.northconcepts.datapipeline.transform.SetBatchSequenceNumberField

public class SetBatchSequenceNumberField
extends Transformer

Adds a sequence (auto increment) field that is incremented with the step value when the value(s) in the specified watch fields differs from the previous record. If no watch fields are specified, the entire record is watched for change. See FieldPath for supported field name expressions.

Constructor Summary

Constructors

Constructor and Description
SetBatchSequenceNumberField(String name, BigDecimal start, BigDecimal step, boolean overwrite, String... watchFields)
SetBatchSequenceNumberField(String name, BigDecimal start, BigDecimal step, String... watchFields)
SetBatchSequenceNumberField(String name, BigInteger start, BigInteger step, boolean overwrite, String... watchFields)
SetBatchSequenceNumberField(String name, BigInteger start, BigInteger step, String... watchFields)
SetBatchSequenceNumberField(String name, double start, double step, boolean overwrite, String... watchFields)
SetBatchSequenceNumberField(String name, double start, double step, String... watchFields)
SetBatchSequenceNumberField(String name, long start, long step, boolean overwrite, String... watchFields)
SetBatchSequenceNumberField(String name, long start, long step, String... watchFields)

Method Summary

Modifier and Type	Method and Description
String	getName()
boolean	getOverwrite()
Number	getStart()
Number	getStep()
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

SetBatchSequenceNumberField

public SetBatchSequenceNumberField(String name,
                                   long start,
                                   long step,
                                   String... watchFields)

SetBatchSequenceNumberField

public SetBatchSequenceNumberField(String name,
                                   double start,
                                   double step,
                                   String... watchFields)

SetBatchSequenceNumberField

public SetBatchSequenceNumberField(String name,
                                   BigDecimal start,
                                   BigDecimal step,
                                   String... watchFields)

SetBatchSequenceNumberField

public SetBatchSequenceNumberField(String name,
                                   BigInteger start,
                                   BigInteger step,
                                   String... watchFields)

SetBatchSequenceNumberField

public SetBatchSequenceNumberField(String name,
                                   long start,
                                   long step,
                                   boolean overwrite,
                                   String... watchFields)

SetBatchSequenceNumberField

public SetBatchSequenceNumberField(String name,
                                   double start,
                                   double step,
                                   boolean overwrite,
                                   String... watchFields)

SetBatchSequenceNumberField

public SetBatchSequenceNumberField(String name,
                                   BigDecimal start,
                                   BigDecimal step,
                                   boolean overwrite,
                                   String... watchFields)

SetBatchSequenceNumberField

public SetBatchSequenceNumberField(String name,
                                   BigInteger start,
                                   BigInteger step,
                                   boolean overwrite,
                                   String... watchFields)

Method Detail

getName

public String getName()

getStart

public Number getStart()

getStep

public Number getStep()

getOverwrite

public boolean getOverwrite()

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