Package | Description |
---|---|
com.pervasive.datarush.analytics.pmml |
Provides shared and base classes for PMML model representation of Analytics algorithms.
|
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.
|
com.pervasive.datarush.operators.group |
Provides data aggregation components.
|
com.pervasive.datarush.operators.io.staging |
Provides operators for reading and writing DataRush staging datasets.
|
com.pervasive.datarush.operators.join |
Provides operators for joining together two data sets into a single one.
|
com.pervasive.datarush.operators.select |
Provides operators for selecting a subset of the data set.
|
com.pervasive.datarush.ports |
Provides classes and interfaces related to receiving and sending data in a dataflow graph.
|
com.pervasive.datarush.ports.model |
Provides implementations of port objects dealing with the flow of single objects
between operators.
|
com.pervasive.datarush.ports.record |
Provides implementations of port objects related to the flow of record sets
between operators.
|
Modifier and Type | Class and Description |
---|---|
class |
PMMLPort
Specialization of model ports for handling PMML models.
|
Modifier and Type | Method and Description |
---|---|
<T extends LogicalPort> |
LogicalSubgraph.filtered(T original,
LogicalPortOptions options)
Provides a filtered view of the original port.
|
Modifier and Type | Method and Description |
---|---|
static List<LogicalStatistic> |
LogicalGraphInstances.getConnectionStatistics(LogicalGraphInstance instance,
LogicalPort inputPort)
Returns the connection statistics associated with the given input port.
|
InputPortInstance |
LogicalGraphInstance.getPortInstance(LogicalPort inputPort)
Looks up an operator instance by the input port of a
LogicalOperator
that was added to the graph. |
Modifier and Type | Interface and Description |
---|---|
interface |
MultiSinkOperator<T extends LogicalPort>
Mix-in interface to be implemented by some operators.
|
interface |
MultiSourceOperator<T extends LogicalPort>
Mix-in interface to be implemented by some operators.
|
interface |
PipelineOperator<T extends LogicalPort>
Mix-in interface to be implemented by some operators.
|
interface |
SinkOperator<T extends LogicalPort>
Mix-in interface to be implemented by some operators.
|
interface |
SourceOperator<T extends LogicalPort>
Mix-in interface to be implemented by some operators.
|
interface |
StagedSource<F extends LogicalPort>
A handle by which one can access the staged data associated with
an iterative port.
|
Modifier and Type | Method and Description |
---|---|
<P extends LogicalPort> |
OperatorComposable.connect(P from,
P to)
Connect two ports together.
|
<T extends LogicalPort> |
IterativeExecutionContext.getStagedSource(T port)
Provides a handle by which one can access the staged data associated with
a given iterative port.
|
protected <T extends LogicalPort> |
AbstractLogicalOperator.newInput(String name,
LogicalPortFactory<T> factory)
Creates a new input port.
|
protected <T extends LogicalPort> |
AbstractLogicalOperator.newInput(String name,
LogicalPortFactory<T> factory,
boolean optional)
Creates a new input port.
|
protected <T extends LogicalPort> |
AbstractLogicalOperator.newOutput(String name,
LogicalPortFactory<T> factory)
Creates a new output port.
|
Modifier and Type | Method and Description |
---|---|
LogicalPort |
OpenComposite.getInput(int index)
Returns the input port of the given port index
|
LogicalPort |
OpenComposite.getOutput(int index)
Returns the output port of the given port index
|
Modifier and Type | Method and Description |
---|---|
Namespace<LogicalPort> |
LogicalOperator.getInputPorts()
Returns the list of input ports.
|
Namespace<LogicalPort> |
AbstractLogicalOperator.getInputPorts() |
Namespace<LogicalPort> |
LogicalOperator.getOutputPorts()
Returns the list of output ports.
|
Namespace<LogicalPort> |
AbstractLogicalOperator.getOutputPorts() |
Modifier and Type | Method and Description |
---|---|
void |
OpenComposite.connectInput(int index,
LogicalPort to) |
void |
OpenComposite.connectOutput(LogicalPort from,
int index) |
PortMetadata |
MetadataContext.getCombinedMetadata(LogicalPort logicalPort)
Returns the source metadata combined with the required metadata to determine the actual metadata
that the operator will receive.
|
PhysicalInputPort |
ExecutionContext.getInputPort(LogicalPort logicalPort)
Returns the physical port for the given logical port.
|
PhysicalInputPort |
ExecutionContext.getInputPort(LogicalPort logicalPort,
int copyNumber)
Returns the physical port for the given logical port.
|
int |
OperatorProxies.ExecutableOperatorProxy.getNumInputCopies(LogicalPort inputPort)
Public only as a matter of implementation; not intended for external use
|
protected int |
ExecutableOperator.getNumInputCopies(LogicalPort inputPort)
May be overridden to specify that multiple input copies are needed for a given
input port.
|
PhysicalOutputPort |
ExecutionContext.getOutputPort(LogicalPort logicalPort)
Returns the physical port for the given logical port.
|
PortSetting[] |
OperatorProxies.ExecutableOperatorProxy.getPortSettings(LogicalPort outputPort)
Public only as a matter of implementation; not intended for external use
|
protected PortSetting[] |
ExecutableOperator.getPortSettings(LogicalPort outputPort)
May be overridden to specify port settings for a given output port
|
PortMetadata |
MetadataContext.getRequiredMetadata(LogicalPort logicalPort)
Gets the required metadata for the given input.
|
int |
MetadataContext.getSourceMaxParallelism(LogicalPort port)
Returns whether the max parallelism of the source of this port.
|
PortMetadata |
MetadataContext.getSourceMetadata(LogicalPort logicalPort)
Returns the source metadata associated with the given port.
|
boolean |
OperatorProxies.ExecutableOperatorProxy.handleInactiveOutput(LogicalPort output)
Public only as a matter of implementation; not intended for external use
|
protected boolean |
ExecutableOperator.handleInactiveOutput(LogicalPort output)
Called when one of our outputs is no longer being read, to perform any cleanup necessary.
|
boolean |
MetadataContext.isSourceConnected(LogicalPort inPort)
Tests whether the given input port is connected.
|
boolean |
MetadataContext.isSourceParallel(LogicalPort port)
Deprecated.
Use
MetadataContext.getSourceMaxParallelism(LogicalPort) instead. |
void |
IterativeMetadataContext.setIterationParallelizable(LogicalPort port,
boolean parallel)
Sets whether the operator will iterate on the given input data in parallel.
|
void |
MetadataCalculationContext.setOutputMetadata(LogicalPort logicalPort,
PortMetadata metadata)
Sets the metadata associated with the given output port
|
void |
IterativeMetadataContext.setOutputMetadataDynamic(LogicalPort port,
boolean dynamic)
Indicates that the metadata for the given output port is dynamic.
|
void |
IterativeMetadataContext.setOutputParallelizable(LogicalPort port,
boolean parallel)
Sets whether the given output port is parallel.
|
void |
MetadataCalculationContext.setRequiredMetadata(LogicalPort logicalPort,
PortMetadata metadata)
Sets the required metadata for the given input.
|
void |
MetadataCalculationContext.setStagingForced(LogicalPort inputPort,
boolean forced)
Can be used to force staging (writing to disk) of input data.
|
Modifier and Type | Method and Description |
---|---|
protected int |
SortedGroupHandler.getNumInputCopies(LogicalPort port)
Overridden to declare that we require 2 copies
of input
|
Modifier and Type | Class and Description |
---|---|
class |
ForceStaging<P extends LogicalPort>
Forces the operators on the input and output sides to
execute sequentially, instead of concurrently.
|
Modifier and Type | Method and Description |
---|---|
protected int |
FilterExistJoinProcess.getNumInputCopies(LogicalPort p) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
FilterRows.handleInactiveOutput(LogicalPort output) |
Modifier and Type | Class and Description |
---|---|
class |
LogicalPortFactory<T extends LogicalPort>
A port factory creates a port.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractModelPort<T>
Common base class for all types of model ports.
|
class |
DoneSignalPort
Used to coordinate processing between operators that have a processing
dependency but no explicit data dependency.
|
class |
SimpleModelPort<T extends Serializable>
A simple implementation for model ports.
|
Modifier and Type | Class and Description |
---|---|
class |
RecordPort
Defines a logical record port.
|
Copyright © 2021 Actian Corporation. All rights reserved.