public class BlockRecords extends CompositeOperator
The output is generated as a set of flows each containing record pairs generated from the input data source. Since the partitioning is based on key values, the output flows may be unbalanced in terms of the number of record pairs contained within each.
Constructor and Description |
---|
BlockRecords()
Generates pairs of records based on matching key fields.
|
Modifier and Type | Method and Description |
---|---|
protected void |
compose(CompositionContext ctx)
Compose the body of this operator.
|
String |
getLeftFieldPattern()
Gets the output naming pattern for fields from the left hand input.
|
RecordPort |
getLeftInput()
Gets the record port providing the left hand input to the pair
generation.
|
String[] |
getLeftKeys()
Gets the fields used as keys for data on the left hand side.
|
RecordPort |
getOutput()
Gets the record port providing the results of the pair generation.
|
String |
getRightFieldPattern()
Gets the output naming pattern for fields from the right hand input.
|
RecordPort |
getRightInput()
Gets the record port providing the right hand input to the pair
generation.
|
String[] |
getRightKeys()
Gets the fields used as keys for data on the right hand side.
|
void |
setLeftFieldPattern(String pattern)
Sets the output naming pattern for fields from the left hand input.
|
void |
setLeftKeys(String[] keys)
Sets the fields used as keys for data on the left hand side.
|
void |
setRightFieldPattern(String pattern)
Sets the output naming pattern for fields from the right hand input.
|
void |
setRightKeys(String[] keys)
Sets the fields used as keys for data on the right hand side.
|
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
public BlockRecords()
setLeftKeys(String[])
,
setRightKeys(String[])
public RecordPort getLeftInput()
public RecordPort getRightInput()
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 right hand side field namespublic String[] getLeftKeys()
public void setLeftKeys(String[] keys)
keys
- the key fields on the left hand sidepublic String[] getRightKeys()
public void setRightKeys(String[] keys)
keys
- the key fields on the right hand sideprotected 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 © 2024 Actian Corporation. All rights reserved.