public class AnalyzeLinkKeys extends CompositeOperator
Constructor and Description |
---|
AnalyzeLinkKeys()
Analyzes the data without blocking keys.
|
Modifier and Type | Method and Description |
---|---|
protected void |
compose(CompositionContext ctx)
Compose the body of this operator.
|
RecordPort |
getLeft()
Gets the record port providing the input data to analyze
for the left side.
|
List<String> |
getLeftBlockingKeys()
Gets the fields to use for key blocking for data on the left.
|
RecordPort |
getRight()
Gets the record port providing the input data to analyze
for the right side.
|
List<String> |
getRightBlockingKeys()
Gets the fields to use for key blocking for data on the right.
|
void |
setLeftBlockingKeys(List<String> keys)
Sets the fields to use for key blocking for data on the left.
|
void |
setRightBlockingKeys(List<String> keys)
Sets the fields to use for key blocking for data on the right.
|
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
public AnalyzeLinkKeys()
setLeftBlockingKeys(List)
and setRightBlockingKeys(List)
.public RecordPort getLeft()
public RecordPort getRight()
public List<String> getRightBlockingKeys()
public void setRightBlockingKeys(List<String> keys)
keys
- the blocking keys for the rightpublic List<String> getLeftBlockingKeys()
public void setLeftBlockingKeys(List<String> keys)
keys
- the blocking keys for the leftprotected 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 © 2020 Actian Corporation. All rights reserved.