Uses of Interface
com.pervasive.datarush.graphs.LogicalGraphInstance

Packages that use LogicalGraphInstance

Package	Description
com.pervasive.datarush.graphs	Provides classes and interfaces for the construction of executable dataflow graphs.
com.pervasive.datarush.operators	Provides classes and interfaces for developing dataflow operators.

Uses of LogicalGraphInstance in com.pervasive.datarush.graphs

Methods in com.pervasive.datarush.graphs that return LogicalGraphInstance

Modifier and Type	Method	Description
LogicalGraphInstance	LogicalGraph.compile()	Creates an executable instance of the logical graph.
LogicalGraphInstance	LogicalGraph.compile(EngineConfig config)	Creates an executable instance of the logical graph.
LogicalGraphInstance	LogicalGraph.run()	Creates an instance of the logical graph and executes it synchronously.
LogicalGraphInstance	LogicalGraph.run(EngineConfig config)	Creates an instance of the logical graph and executes it synchronously.

Methods in com.pervasive.datarush.graphs with parameters of type LogicalGraphInstance

Modifier and Type	Method	Description
static List<LogicalStatistic>	LogicalGraphInstances.getConnectionStatistics(LogicalGraphInstance instance, LogicalPort inputPort)	Returns the connection statistics associated with the given input port.
static List<Throwable>	LogicalGraphInstances.getExceptions(LogicalGraphInstance instance, LogicalOperator operator)	Returns the exceptions associated with the given operator.
static OperatorState	LogicalGraphInstances.getOperatorState(LogicalGraphInstance instance, LogicalOperator operator)	Returns the operator state associated with the given operator.
static List<LogicalStatistic>	LogicalGraphInstances.getOperatorStatistics(LogicalGraphInstance instance, LogicalOperator operator)	Returns the operator statistics associated with the given operator.

Uses of LogicalGraphInstance in com.pervasive.datarush.operators

Methods in com.pervasive.datarush.operators that return LogicalGraphInstance

Modifier and Type	Method	Description
protected LogicalGraphInstance	AbstractOperatorTestCase.compile(LogicalGraph graph)
LogicalGraphInstance	OperatorTestHelper.compile(LogicalGraph graph)
protected LogicalGraphInstance	AbstractOperatorTestCase.run(LogicalGraph graph)
LogicalGraphInstance	OperatorTestHelper.run(LogicalGraph graph)
protected LogicalGraphInstance	AbstractOperatorTestCase.testClusterDistributedOutput(LogicalGraph graph, RecordPort port, String testName, int partitions)
protected LogicalGraphInstance	AbstractOperatorTestCase.testClusterOutput(LogicalGraph graph, RecordPort port, String testName, int partitions)
protected LogicalGraphInstance	AbstractOperatorTestCase.testDistributedOutput(LogicalGraph graph, RecordPort port, String testName)
protected LogicalGraphInstance	AbstractOperatorTestCase.testDistributedOutput(LogicalGraph graph, RecordPort port, String testName, boolean sort)
protected LogicalGraphInstance	AbstractOperatorTestCase.testDistributedOutput(LogicalGraph graph, RecordPort port, String testName, int partitions)
LogicalGraphInstance	OperatorTestHelper.testDistributedOutput(LogicalGraph graph, RecordPort port)
LogicalGraphInstance	OperatorTestHelper.testDistributedOutput(LogicalGraph graph, RecordPort port, boolean sort)
protected LogicalGraphInstance	AbstractOperatorTestCase.testLocalOutput(LogicalGraph graph, RecordPort port, String testName)
protected LogicalGraphInstance	AbstractOperatorTestCase.testLocalOutput(LogicalGraph graph, RecordPort port, String testName, boolean sort)
protected LogicalGraphInstance	AbstractOperatorTestCase.testLocalOutput(LogicalGraph graph, RecordPort port, String testName, int partitions)
LogicalGraphInstance	OperatorTestHelper.testLocalOutput(LogicalGraph graph, RecordPort port)
LogicalGraphInstance	OperatorTestHelper.testLocalOutput(LogicalGraph graph, RecordPort port, boolean sort)

Methods in com.pervasive.datarush.operators with parameters of type LogicalGraphInstance

Modifier and Type	Method	Description
static void	OperatorTestHelper.assertTokenCount(LogicalGraphInstance instance, LogicalPort inputPort, long value)