Uses of Class
com.pervasive.datarush.ports.LogicalPort

Packages that use LogicalPort

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.

Uses of LogicalPort in com.pervasive.datarush.analytics.pmml

Subclasses of LogicalPort in com.pervasive.datarush.analytics.pmml

Modifier and Type	Class and Description
class	PMMLPort Specialization of model ports for handling PMML models.

Uses of LogicalPort in com.pervasive.datarush.graphs

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

Modifier and Type	Method and Description
<T extends LogicalPort> T	LogicalSubgraph.filtered(T original, LogicalPortOptions options) Provides a filtered view of the original port.

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

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.

Uses of LogicalPort in com.pervasive.datarush.operators

Classes in com.pervasive.datarush.operators with type parameters of type LogicalPort

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.

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

Modifier and Type	Method and Description
<P extends LogicalPort> void	OperatorComposable.connect(P from, P to) Connect two ports together.
<T extends LogicalPort> StagedSource<T>	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> T	AbstractLogicalOperator.newInput(String name, LogicalPortFactory<T> factory) Creates a new input port.
protected <T extends LogicalPort> T	AbstractLogicalOperator.newInput(String name, LogicalPortFactory<T> factory, boolean optional) Creates a new input port.
protected <T extends LogicalPort> T	AbstractLogicalOperator.newOutput(String name, LogicalPortFactory<T> factory) Creates a new output port.

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

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

Methods in com.pervasive.datarush.operators that return types with arguments of type LogicalPort

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()

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

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.

Uses of LogicalPort in com.pervasive.datarush.operators.group

Methods in com.pervasive.datarush.operators.group with parameters of type LogicalPort

Modifier and Type	Method and Description
protected int	SortedGroupHandler.getNumInputCopies(LogicalPort port) Overridden to declare that we require 2 copies of input

Uses of LogicalPort in com.pervasive.datarush.operators.io.staging

Classes in com.pervasive.datarush.operators.io.staging with type parameters of type LogicalPort

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.

Uses of LogicalPort in com.pervasive.datarush.operators.join

Methods in com.pervasive.datarush.operators.join with parameters of type LogicalPort

Modifier and Type	Method and Description
protected int	FilterExistJoinProcess.getNumInputCopies(LogicalPort p)

Uses of LogicalPort in com.pervasive.datarush.operators.select

Methods in com.pervasive.datarush.operators.select with parameters of type LogicalPort

Modifier and Type	Method and Description
protected boolean	FilterRows.handleInactiveOutput(LogicalPort output)

Uses of LogicalPort in com.pervasive.datarush.ports

Classes in com.pervasive.datarush.ports with type parameters of type LogicalPort

Modifier and Type	Class and Description
class	LogicalPortFactory<T extends LogicalPort> A port factory creates a port.

Uses of LogicalPort in com.pervasive.datarush.ports.model

Subclasses of LogicalPort in com.pervasive.datarush.ports.model

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.

Uses of LogicalPort in com.pervasive.datarush.ports.record

Subclasses of LogicalPort in com.pervasive.datarush.ports.record

Modifier and Type	Class and Description
class	RecordPort Defines a logical record port.