- java.lang.Object
-
- com.pervasive.datarush.operators.AbstractLogicalOperator
-
- com.pervasive.datarush.operators.CompositeOperator
-
- com.pervasive.datarush.operators.testutils.DumpPartitions
-
- All Implemented Interfaces:
LogicalOperator
public final class DumpPartitions extends CompositeOperator
For test purposes--sorts inputs and writes to a file
-
-
Constructor Summary
Constructors Constructor Description DumpPartitions(String path)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidcompose(CompositionContext ctx)Compose the body of this operator.RecordPortgetInput()StringgetPath()booleanisSort()booleanisWriteOnClient()voidsetSort(boolean sort)voidsetWriteOnClient(boolean writeOnClient)-
Methods inherited from class com.pervasive.datarush.operators.AbstractLogicalOperator
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
-
-
-
-
Constructor Detail
-
DumpPartitions
public DumpPartitions(String path)
-
-
Method Detail
-
getPath
public String getPath()
-
getInput
public RecordPort getInput()
-
isSort
public boolean isSort()
-
setSort
public void setSort(boolean sort)
-
compose
protected void compose(CompositionContext ctx)
Description copied from class:CompositeOperatorCompose the body of this operator. Implementations should do the following:- Perform any validation of configuration, input types, etc
- Instantiate and configure sub-operators, adding them to the provided context via
the method
OperatorComposable.add(O) - Create necessary connections via the method
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 ports
- Specified by:
composein classCompositeOperator- Parameters:
ctx- the context
-
isWriteOnClient
public boolean isWriteOnClient()
-
setWriteOnClient
public void setWriteOnClient(boolean writeOnClient)
-
-