public class RemapFields extends ExecutableOperator implements RecordPipelineOperator
SelectFields
.SelectFields
,
RetainFields
,
RemoveFields
Constructor and Description |
---|
RemapFields()
Maps all fields in the input to the same fields in the output.
|
RemapFields(FieldRemapping remapping)
Maps fields in the input to fields in the
output using the specified mapping.
|
Modifier and Type | Method and Description |
---|---|
protected ExecutableOperator |
cloneForExecution()
Performs a deep copy of the operator for execution.
|
protected void |
computeMetadata(StreamingMetadataContext ctx)
Implementations must adhere to the following contracts
|
protected void |
execute(ExecutionContext ctx)
Executes the operator.
|
FieldRemapping |
getFieldRemapping()
Gets how input fields are mapped to output fields,
|
RecordPort |
getInput()
Returns the input port
|
RecordPort |
getOutput()
Returns the output port
|
void |
setFieldRemapping(FieldRemapping remapping)
Defines how input fields are to be mapped to output
fields.
|
getNumInputCopies, getPortSettings, handleInactiveOutput
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
disableParallelism, getInputPorts, getOutputPorts
public RemapFields()
setFieldRemapping(FieldRemapping)
to define
a mapping to apply.public RemapFields(FieldRemapping remapping)
remapping
- a mapping defining how input fields
are mapped to output fieldspublic RecordPort getInput()
PipelineOperator
getInput
in interface PipelineOperator<RecordPort>
public RecordPort getOutput()
PipelineOperator
getOutput
in interface PipelineOperator<RecordPort>
public FieldRemapping getFieldRemapping()
public void setFieldRemapping(FieldRemapping remapping)
remapping
- a mapping defining how input fields
are mapped to output fieldsprotected void computeMetadata(StreamingMetadataContext ctx)
StreamingOperator
StreamingMetadataContext.parallelize(ParallelismStrategy)
.
RecordPort#setRequiredDataOrdering
, otherwise data may arrive in any order.
RecordPort#setRequiredDataDistribution
, otherwise data will arrive in an unspecified partial distribution
.
RecordPort#getSourceDataDistribution
and RecordPort#getSourceDataOrdering
. These should be
viewed as a hints to help chose a more efficient algorithm. In such cases, though, operators must
still declare data ordering and data distribution requirements; otherwise there is no guarantee that
data will arrive sorted/distributed as required.
RecordPort#setType
.RecordPort#setOutputDataOrdering
RecordPort#setOutputDataDistribution
AbstractModelPort#setMergeHandler
.MergeModel
is a convenient, re-usable model reducer, parameterized with
a merge-handler.
SimpleModelPort
's have no associated metadata and therefore there is
never any output metadata to declare. PMMLPort
's, on the other hand,
do have associated metadata. For all PMMLPorts, implementations must declare
the following:
PMMLPort.setPMMLModelSpec
.
computeMetadata
in class StreamingOperator
ctx
- the contextprotected void execute(ExecutionContext ctx)
ExecutableOperator
execute
in class ExecutableOperator
ctx
- context in which to lookup physical ports bound to logical portsprotected ExecutableOperator cloneForExecution()
ExecutableOperator
cloneForExecution
in class ExecutableOperator
Copyright © 2016 Actian Corporation. All rights reserved.