This is used in every Joiner and also in Reformat and DataIntersection.
The transformation implements methods of the RecordTransform interface
and inherits other common methods from the Transform interface.
See Common Java Interfaces.
Following are the methods of the
RecordTransform interface:
boolean init(Properties parameters,
DataRecordMetadata[] sourcesMetadata, DataRecordMetadata[]
targetMetadata)
Initializes reformat class/function. This method is called only once at the beginning of transformation process. Any object allocation/initialization should happen here.
int transform(DataRecord[] sources, DataRecord[] target)
Performs reformat of source records to target records. This method is called as one step in transforming flow of records. See Return Values of Transformations for detailed information about return values and their meaning.
int transformOnError(Exception exception, DataRecord[] sources, DataRecord[] target)
Performs reformat of source records to target records.
This method is called as one step in transforming flow of records.
See Return Values of Transformations for detailed
information about return values and their meaning.
Called only if transform(DataRecord[], DataRecord[]) throws an exception.
void signal(Object signalObject)
Method which can be used for signalling into transformation that something outside happened. (For example in aggregation component key changed.)
Object getSemiResult()
Method which can be used for getting intermediate results out of transformation. May or may not be implemented.