Module datarush.library
Package com.pervasive.datarush.ports.record
package com.pervasive.datarush.ports.record
Provides implementations of port objects related to the flow of record sets
between operators. Record sets are assumed to be too large to fit into
memory all at once and are therefore handled in a streaming fashion. Data
is accessed one record at a time, using physical ports which
are created at runtime for this purpose.
-
ClassDescriptionAn alias set consists of a set of name aliases and optionally a token order.Used to redistribute the data in a roughly balanced fashion.DataDistribution is the component of
RecordMetadatathat describes how the data is distributed.DataOrdering is the component ofRecordMetadatathat describes how the data is ordered.Can be used to provide tuning parameters that control how iterative operators stage their data.A distribution where data is range-partitioned by a selected array of keys.Defines an external sink of record data.Defines an external source of record data.An operator may set this as theirrequiredDataDistributionin order to indicate that the data needs to be sent to all nodes in the cluster (or all threads in the case of pseudo-distributed operation).A default hash partitioning functionDataDistribution based on a set of keys from the input data.Provides utility methods for working with port metadata.Base class for all distributions that represent a partitioning of the data.Base class for all distributions whose partitioning parameters are based on the data.Base class for all distributions whose partitioning parameters are specified statically.Represents a pluggable partitioning function; for use by operators that require custom partitioningComputes partition assignments for each row if inputContextual information forPartitioningFunction's.A partitioning function that partitions records of data based on specified ranges.The metadata associated with record ports.Defines a logical record port.Provides a way for iterative operators to select a filtered view of one of their input ports.The default data distribution; if unspecified an operator will receive data in the same distribution as the upstream operator.