Module datarush.library

Package com.pervasive.datarush.operators

Class OperatorTestHelper

java.lang.Object

com.pervasive.datarush.operators.OperatorTestHelper

public final class OperatorTestHelper
extends Object

Constructor Summary

Constructors

Constructor	Description
OperatorTestHelper(Class<?> relativeTo, String testName)

Method Summary

Modifier and Type	Method	Description
void	assertDirectoriesEqual(File expectedPath, File actualPath)
void	assertDirectoriesEqual(String expectedPath, String actualPath)
static void	assertTokenCount(LogicalGraphInstance instance, LogicalPort inputPort, long value)
LogicalGraphInstance	compile(LogicalGraph graph)
EngineConfig	createTestConfig()
String	distributedExpectedPath()
DumpPartitions	distributedOutput(OperatorComposable graph, RecordPort port, boolean sort)
void	enableCluster(int parallelism)
void	enableStatsDump()
Assertions.MismatchFilter	getMismatchFilter()
int	getParallelism()
String	localExpectedPath()
DumpPartitions	localOutput(OperatorComposable graph, RecordPort port, boolean sort)
void	negativeCompile(LogicalGraph graph)
void	negativeRun(LogicalGraph graph)
LogicalGraphInstance	run(LogicalGraph graph)
OperatorTestHelper	setBatchSize(int batchSize)
void	setMismatchFilter(Assertions.MismatchFilter filter)
void	setOutputNameBase(String name)
void	setParallelism(int parallelism)
LogicalGraphInstance	testDistributedOutput(LogicalGraph graph, RecordPort port)
LogicalGraphInstance	testDistributedOutput(LogicalGraph graph, RecordPort port, boolean sort)
LogicalGraphInstance	testLocalOutput(LogicalGraph graph, RecordPort port)
LogicalGraphInstance	testLocalOutput(LogicalGraph graph, RecordPort port, boolean sort)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorTestHelper

public OperatorTestHelper(Class<?> relativeTo,
                          String testName)

Method Detail

setBatchSize

public OperatorTestHelper setBatchSize(int batchSize)

setOutputNameBase

public void setOutputNameBase(String name)

getParallelism

public int getParallelism()

setParallelism

public void setParallelism(int parallelism)

enableCluster

public void enableCluster(int parallelism)

enableStatsDump

public void enableStatsDump()

createTestConfig

public final EngineConfig createTestConfig()

assertTokenCount

public static final void assertTokenCount(LogicalGraphInstance instance,
                                          LogicalPort inputPort,
                                          long value)

getMismatchFilter

public Assertions.MismatchFilter getMismatchFilter()

setMismatchFilter

public void setMismatchFilter(Assertions.MismatchFilter filter)

compile

public final LogicalGraphInstance compile(LogicalGraph graph)

run

public final LogicalGraphInstance run(LogicalGraph graph)

testLocalOutput

public final LogicalGraphInstance testLocalOutput(LogicalGraph graph,
                                                  RecordPort port)

localOutput

public DumpPartitions localOutput(OperatorComposable graph,
                                  RecordPort port,
                                  boolean sort)

localExpectedPath

public String localExpectedPath()

testLocalOutput

public final LogicalGraphInstance testLocalOutput(LogicalGraph graph,
                                                  RecordPort port,
                                                  boolean sort)

testDistributedOutput

public final LogicalGraphInstance testDistributedOutput(LogicalGraph graph,
                                                        RecordPort port)

distributedOutput

public DumpPartitions distributedOutput(OperatorComposable graph,
                                        RecordPort port,
                                        boolean sort)

distributedExpectedPath

public String distributedExpectedPath()

testDistributedOutput

public final LogicalGraphInstance testDistributedOutput(LogicalGraph graph,
                                                        RecordPort port,
                                                        boolean sort)

assertDirectoriesEqual

public final void assertDirectoriesEqual(String expectedPath,
                                         String actualPath)

assertDirectoriesEqual

public final void assertDirectoriesEqual(File expectedPath,
                                         File actualPath)

negativeCompile

public final void negativeCompile(LogicalGraph graph)

negativeRun

public final void negativeRun(LogicalGraph graph)
                       throws Exception

Throws:

Exception