- 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 void
compose(CompositionContext ctx)
Compose the body of this operator.RecordPort
getInput()
String
getPath()
boolean
isSort()
boolean
isWriteOnClient()
void
setSort(boolean sort)
void
setWriteOnClient(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:CompositeOperator
Compose 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:
compose
in classCompositeOperator
- Parameters:
ctx
- the context
-
isWriteOnClient
public boolean isWriteOnClient()
-
setWriteOnClient
public void setWriteOnClient(boolean writeOnClient)
-
-