Module datarush.library

Package com.pervasive.datarush.operators.testutils

Class DumpPartitions

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DumpPartitions

public DumpPartitions(String path)

Method Details

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:

1. Perform any validation of configuration, input types, etc
2. Instantiate and configure sub-operators, adding them to the provided context via the method OperatorComposable.add(O)
3. 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 class CompositeOperator

Parameters:

ctx - the context

isWriteOnClient

public boolean isWriteOnClient()

setWriteOnClient

public void setWriteOnClient(boolean writeOnClient)