java.lang.Object
com.pervasive.datarush.operators.OperatorTestHelper
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionfinal voidassertDirectoriesEqual(File expectedPath, File actualPath) final voidassertDirectoriesEqual(String expectedPath, String actualPath) static final voidassertTokenCount(LogicalGraphInstance instance, LogicalPort inputPort, long value) final LogicalGraphInstancecompile(LogicalGraph graph) final EngineConfigdistributedOutput(OperatorComposable graph, RecordPort port, boolean sort) voidenableCluster(int parallelism) voidintlocalOutput(OperatorComposable graph, RecordPort port, boolean sort) final voidnegativeCompile(LogicalGraph graph) final voidnegativeRun(LogicalGraph graph) final LogicalGraphInstancerun(LogicalGraph graph) setBatchSize(int batchSize) voidvoidsetOutputNameBase(String name) voidsetParallelism(int parallelism) final LogicalGraphInstancetestDistributedOutput(LogicalGraph graph, RecordPort port) final LogicalGraphInstancetestDistributedOutput(LogicalGraph graph, RecordPort port, boolean sort) final LogicalGraphInstancetestLocalOutput(LogicalGraph graph, RecordPort port) final LogicalGraphInstancetestLocalOutput(LogicalGraph graph, RecordPort port, boolean sort)
-
Constructor Details
-
OperatorTestHelper
-
-
Method Details
-
setBatchSize
-
setOutputNameBase
-
getParallelism
public int getParallelism() -
setParallelism
public void setParallelism(int parallelism) -
enableCluster
public void enableCluster(int parallelism) -
enableStatsDump
public void enableStatsDump() -
createTestConfig
-
assertTokenCount
public static final void assertTokenCount(LogicalGraphInstance instance, LogicalPort inputPort, long value) -
getMismatchFilter
-
setMismatchFilter
-
compile
-
run
-
testLocalOutput
-
localOutput
-
localExpectedPath
-
testLocalOutput
public final LogicalGraphInstance testLocalOutput(LogicalGraph graph, RecordPort port, boolean sort) -
testDistributedOutput
-
distributedOutput
-
distributedExpectedPath
-
testDistributedOutput
public final LogicalGraphInstance testDistributedOutput(LogicalGraph graph, RecordPort port, boolean sort) -
assertDirectoriesEqual
-
assertDirectoriesEqual
-
negativeCompile
-
negativeRun
- Throws:
Exception
-