Uses of Interface
com.pervasive.datarush.graphs.LogicalGraphInstance
Packages that use LogicalGraphInstance
Package
Description
Provides classes and interfaces for the construction of executable
dataflow graphs.
Provides classes and interfaces for developing dataflow operators.
-
Uses of LogicalGraphInstance in com.pervasive.datarush.graphs
Methods in com.pervasive.datarush.graphs that return LogicalGraphInstanceModifier and TypeMethodDescriptionLogicalGraph.compile()Creates an executable instance of the logical graph.LogicalGraph.compile(EngineConfig config) Creates an executable instance of the logical graph.LogicalGraph.run()Creates an instance of the logical graph and executes it synchronously.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 LogicalGraphInstanceModifier and TypeMethodDescriptionstatic List<LogicalStatistic>LogicalGraphInstances.getConnectionStatistics(LogicalGraphInstance instance, LogicalPort inputPort) Returns the connection statistics associated with the given input port.LogicalGraphInstances.getExceptions(LogicalGraphInstance instance, LogicalOperator operator) Returns the exceptions associated with the given operator.static OperatorStateLogicalGraphInstances.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 LogicalGraphInstanceModifier and TypeMethodDescriptionprotected final LogicalGraphInstanceAbstractOperatorTestCase.compile(LogicalGraph graph) final LogicalGraphInstanceOperatorTestHelper.compile(LogicalGraph graph) protected final LogicalGraphInstanceAbstractOperatorTestCase.run(LogicalGraph graph) final LogicalGraphInstanceOperatorTestHelper.run(LogicalGraph graph) protected final LogicalGraphInstanceAbstractOperatorTestCase.testClusterDistributedOutput(LogicalGraph graph, RecordPort port, String testName, int partitions) protected final LogicalGraphInstanceAbstractOperatorTestCase.testClusterOutput(LogicalGraph graph, RecordPort port, String testName, int partitions) protected final LogicalGraphInstanceAbstractOperatorTestCase.testDistributedOutput(LogicalGraph graph, RecordPort port, String testName) protected final LogicalGraphInstanceAbstractOperatorTestCase.testDistributedOutput(LogicalGraph graph, RecordPort port, String testName, boolean sort) protected final LogicalGraphInstanceAbstractOperatorTestCase.testDistributedOutput(LogicalGraph graph, RecordPort port, String testName, int partitions) final LogicalGraphInstanceOperatorTestHelper.testDistributedOutput(LogicalGraph graph, RecordPort port) final LogicalGraphInstanceOperatorTestHelper.testDistributedOutput(LogicalGraph graph, RecordPort port, boolean sort) protected final LogicalGraphInstanceAbstractOperatorTestCase.testLocalOutput(LogicalGraph graph, RecordPort port, String testName) protected final LogicalGraphInstanceAbstractOperatorTestCase.testLocalOutput(LogicalGraph graph, RecordPort port, String testName, boolean sort) protected final LogicalGraphInstanceAbstractOperatorTestCase.testLocalOutput(LogicalGraph graph, RecordPort port, String testName, int partitions) final LogicalGraphInstanceOperatorTestHelper.testLocalOutput(LogicalGraph graph, RecordPort port) final LogicalGraphInstanceOperatorTestHelper.testLocalOutput(LogicalGraph graph, RecordPort port, boolean sort) Methods in com.pervasive.datarush.operators with parameters of type LogicalGraphInstanceModifier and TypeMethodDescriptionstatic final voidOperatorTestHelper.assertTokenCount(LogicalGraphInstance instance, LogicalPort inputPort, long value)