Package com.pervasive.datarush.ports.physical

Provides classes and interfaces for accessing and producing the data flowing between operators in a dataflow graph.

See: Description

Interface Summary

Interface	Description
BinaryInputField	A binary valued field of a record input port.
BinaryOutputField	A binary valued field of a record output port.
BooleanInputField	A boolean valued field of a record input port.
BooleanOutputField	A boolean valued field of a record output port.
CharInputField	A character valued field of a record input port.
CharOutputField	A character valued field of a record output port.
DateInputField	A date valued field of a record input port.
DateOutputField	A date valued field of a record output port.
DoubleInputField	A double valued field of a record input port.
DoubleOutputField	A double valued field of a record output port.
DurationInputField	A duration valued field of a record input port.
DurationOutputField	A duration valued field of a record output port.
FloatInputField	A float valued field of a record input port.
FloatOutputField	A float valued field of a record output port.
GenericPushable	An object publishing buffered data.
InputStatistics	Live run-time statistics for an input port.
IntInputField	An integer valued field of a record input port.
IntOutputField	An integer valued field of a record output port.
Ip4AddressInputField	A ip4 address valued field of a record input port.
Ip4AddressOutputField	A ip4 address valued field of a record output port.
Ip6AddressInputField	A ip6 address valued field of a record input port.
Ip6AddressOutputField	A ip6 address valued field of a record output port.
LongInputField	A long valued field of a record input port.
LongOutputField	A long valued field of a record output port.
MoneyInputField	A money valued field of a record input port.
MoneyOutputField	A money valued field of a record output port.
NumberOutputField	A number valued field of a record output port.
NumericInputField	A numeric valued field of a record input port.
NumericOutputField	A numeric valued field of a record output port.
ObjectInputField<T>	An object valued field of a record input port.
ObjectOutputField<T>	An object valued field of a record output port.
OutputEventListener	A callback interface for handling events occurring on an output port.
OutputStatistics	Live run-time statistics for an input port.
PeriodInputField	A period valued field of a record input port.
PeriodOutputField	A period valued field of a record output port.
PortStatistics	Live run-time statistics for a dataflow port.
RecordInput	An input port on a record data flow.
RecordInputSelector	Provides a mechanism to wait for data on a set of RecordInput objects.
RecordOutput	An output port generating a flow of record tokens.
ScalarInputField	A field of a record input port.
ScalarOutputField	A field of a record output port.
SteppableRecordValued
StringInputField	A string valued field of a record input port.
StringOutputField	A string valued field of a record output port.
TimeInputField	A time valued field of a record input port.
TimeOutputField	A time valued field of a record output port.
TimestampInputField	A timestamp valued field of a record input port.
TimestampOutputField	A timestamp valued field of a record output port.

Class Summary

Class	Description
FieldCopier	A utility class for copying a set of input values to output fields.
InputSnapshot	A snapshot of run-time statistics for an input port.
OutputSnapshot	A snapshot of run-time statistics for an output port.
PortSnapshot	A snapshot of run-time statistics for a dataflow port.

Enum Summary

Enum	Description
PortStatus	Possible states for a port.

Exception Summary

Exception	Description
BrokenFlowError	An error indicating premature termination of a data flow.
EndOfDataException	Exception thrown when an error relating to reaching the end of a flow is encountered.

Package com.pervasive.datarush.ports.physical Description

Provides classes and interfaces for accessing and producing the data flowing between operators in a dataflow graph. Physical ports are obtained from the ExecutionContext in order to send or receive data through a record port.

While physical ports provide a safe communication channel between operators which may be executing on different thread, they are not thread-safe; physical ports cannot be shared between multiple threads. Failure to observe this restriction may result in data corruption or deadlocks in the dataflow.