Module datarush.library
Package com.pervasive.datarush.ports.physical
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.
-
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 ofRecordInputobjects.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.