public class BlockSelf extends CompositeOperator
Constructor and Description |
---|
BlockSelf()
Block records from a single source.
|
Modifier and Type | Method and Description |
---|---|
protected void |
compose(CompositionContext ctx)
Compose the body of this operator.
|
RecordPort |
getInput()
Gets the record port providing the input to the pair
generation.
|
String[] |
getKeys()
Get the fields being used for blocking
|
String |
getLeftFieldPattern()
Gets the output naming pattern for fields on the left hand side of
the pair.
|
RecordPort |
getOutput()
Gets the record port providing the results of the pair generation.
|
String |
getRightFieldPattern()
Gets the output naming pattern for fields on the right hand side of
the pair.
|
void |
setKeys(String[] keys)
Set the fields to use as keys for blocking.
|
void |
setLeftFieldPattern(String pattern)
Sets the output naming pattern for fields on the left hand side of
pairs.
|
void |
setRightFieldPattern(String pattern)
Sets the output naming pattern for fields on the right hand side of
pairs.
|
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
public BlockSelf()
setKeys(String[])
public RecordPort getInput()
public RecordPort getOutput()
public String getLeftFieldPattern()
public void setLeftFieldPattern(String pattern)
pattern
- name pattern for the left hand side field namespublic String getRightFieldPattern()
public void setRightFieldPattern(String pattern)
pattern
- name pattern for the eight hand side field namespublic String[] getKeys()
public void setKeys(String[] keys)
keys
- the set of key fieldsprotected void compose(CompositionContext ctx)
CompositeOperator
OperatorComposable.add(O)
OperatorComposable.connect(P, P)
. This includes
connections from the composite's input ports to sub-operators, connections between sub-operators, and
connections from sub-operators output ports to the composite's output portscompose
in class CompositeOperator
ctx
- the contextCopyright © 2016 Actian Corporation. All rights reserved.