public class FilterExistJoinProcess extends ExecutableOperator
Constructor and Description |
---|
FilterExistJoinProcess() |
Modifier and Type | Method and Description |
---|---|
protected void |
computeMetadata(StreamingMetadataContext ctx)
Implementations must adhere to the following contracts
|
protected void |
execute(ExecutionContext ctx)
Executes the operator.
|
RecordPort |
getAntioutput() |
ScalarValuedFunction |
getJoinCondition() |
JoinKey[] |
getJoinKeys() |
RecordPort |
getLeft() |
protected int |
getNumInputCopies(LogicalPort p)
May be overridden to specify that multiple input copies are needed for a given
input port.
|
RecordPort |
getOutput() |
RecordPort |
getRight() |
void |
setJoinCondition(ScalarValuedFunction joinCondition) |
void |
setJoinKeys(JoinKey[] joinKeys) |
cloneForExecution, getPortSettings, handleInactiveOutput
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
public final ScalarValuedFunction getJoinCondition()
public final void setJoinCondition(ScalarValuedFunction joinCondition)
public final JoinKey[] getJoinKeys()
public void setJoinKeys(JoinKey[] joinKeys)
public final RecordPort getLeft()
public final RecordPort getRight()
public final RecordPort getOutput()
public final RecordPort getAntioutput()
protected final void computeMetadata(StreamingMetadataContext ctx)
StreamingOperator
StreamingMetadataContext.parallelize(ParallelismStrategy)
.
RecordPort.setRequiredDataOrdering(com.pervasive.datarush.operators.MetadataCalculationContext, com.pervasive.datarush.ports.record.DataOrdering)
, otherwise data may arrive in any order.
RecordPort.setRequiredDataDistribution(com.pervasive.datarush.operators.MetadataCalculationContext, com.pervasive.datarush.ports.record.DataDistribution)
, otherwise data will arrive in an unspecified partial distribution
.
RecordPort.getSourceDataDistribution(com.pervasive.datarush.operators.MetadataContext)
and RecordPort.getSourceDataOrdering(com.pervasive.datarush.operators.MetadataContext)
. 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(com.pervasive.datarush.operators.MetadataCalculationContext, com.pervasive.datarush.types.RecordTokenType)
.RecordPort.setOutputDataOrdering(com.pervasive.datarush.operators.MetadataCalculationContext, com.pervasive.datarush.ports.record.DataOrdering)
RecordPort.setOutputDataDistribution(com.pervasive.datarush.operators.MetadataCalculationContext, com.pervasive.datarush.ports.record.DataDistribution)
AbstractModelPort.setMergeHandler(com.pervasive.datarush.operators.MetadataCalculationContext, com.pervasive.datarush.ports.model.ModelMergeHandler<T>)
.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 final int getNumInputCopies(LogicalPort p)
ExecutableOperator
getNumInputCopies
in class ExecutableOperator
p
- the portCopyright © 2015 Actian Corporation. All Rights Reserved.