Package | Description |
---|---|
com.pervasive.datarush.encoding |
Provides basic interfaces used when converting tokens
into various formats.
|
com.pervasive.datarush.functions |
Provides classes and interfaces related to defining functions on records.
|
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.ports.physical |
Provides classes and interfaces for accessing and producing the data flowing
between operators in a dataflow graph.
|
com.pervasive.datarush.sequences.scalar |
Provides implementations of sequences of scalar token values.
|
com.pervasive.datarush.tokens |
Provides classes and utilities for working with data tokens.
|
com.pervasive.datarush.tokens.record |
Provides implementations of and utilities for record valued
tokens.
|
com.pervasive.datarush.tokens.scalar |
Provides implementations of and utilities for scalar valued
tokens.
|
com.pervasive.datarush.types |
Provides classes and interfaces for the description of token data types.
|
Modifier and Type | Method and Description |
---|---|
void |
TokenFormatter.setSource(ScalarValued source)
Sets the container holding values to be formatted.
|
Modifier and Type | Method and Description |
---|---|
ScalarValued |
EvaluationContext.constructSubexpressionEvaluation(EvaluatorFactory factory,
List<Object> arguments,
ScalarTokenType resultType)
Creates an evaluation of a subexpression which can be used as input to the
evaluator of the expression containing it.
|
ScalarValued |
ScalarValuedFunction.getSubexpressionEvaluation(EvaluationContext ctx)
Constructs an instance of an evaluation of the function in the context
of a larger expression.
|
ScalarValued |
FieldReference.getSubexpressionEvaluation(EvaluationContext ctx) |
ScalarValued |
ConstantReference.getSubexpressionEvaluation(EvaluationContext ctx) |
Modifier and Type | Method and Description |
---|---|
static ScalarValuedFunction |
Predicates.eq(String field,
ScalarValued value)
Builds a record predicate which tests the equality of
the specified field with a known value.
|
static ScalarValuedFunction |
Predicates.gt(String leftField,
ScalarValued rightValue)
Builds a record predicate which tests whether a field is
strictly greater than a known value.
|
static ScalarValuedFunction |
Predicates.gte(String leftField,
ScalarValued rightValue)
Builds a record predicate which tests whether a field is
greater than or equal to a known value.
|
static ScalarValuedFunction |
Predicates.lt(String leftField,
ScalarValued rightValue)
Builds a record predicate which tests whether a field is
strictly less than a known value.
|
static ScalarValuedFunction |
Predicates.lte(String leftField,
ScalarValued rightValue)
Builds a record predicate which tests whether a field is
less than or equal to a known value.
|
static ScalarValuedFunction |
Predicates.neq(String field,
ScalarValued value)
Builds a record predicate which tests the inequality of
the specified field with a known value.
|
Constructor and Description |
---|
ConstantReference(ScalarValued v)
Defines a function evaluating to the specified value
|
Modifier and Type | Method and Description |
---|---|
ScalarValued |
ReadableStorage.getScalarValued(int offset)
Returns the value of the internal element at the given offset.
|
Modifier and Type | Method and Description |
---|---|
void |
Aggregator.setInputs(ScalarValued[] inputs)
Binds the input values for this aggregator.
|
Constructor and Description |
---|
ReadableStorage(ScalarValued[] internals)
Create a new readable storage.
|
Modifier and Type | Method and Description |
---|---|
ScalarValued |
DatasetIterator.getField(int index) |
ScalarValued |
DatasetIterator.getField(String fieldName) |
ScalarValued[] |
DatasetIterator.getFields() |
Modifier and Type | Interface and Description |
---|---|
interface |
BinaryInputField
A binary valued field of a record input port.
|
interface |
BooleanInputField
A boolean valued field of a record input port.
|
interface |
CharInputField
A character valued field of a record input port.
|
interface |
DateInputField
A date valued field of a record input port.
|
interface |
DoubleInputField
A double valued field of a record input port.
|
interface |
DurationInputField
A duration valued field of a record input port.
|
interface |
FloatInputField
A float valued field of a record input port.
|
interface |
IntInputField
An integer valued field of a record input port.
|
interface |
Ip4AddressInputField
A ip4 address valued field of a record input port.
|
interface |
Ip6AddressInputField
A ip6 address valued field of a record input port.
|
interface |
LongInputField
A long valued field of a record input port.
|
interface |
MoneyInputField
A money valued field of a record input port.
|
interface |
NumericInputField
A numeric valued field of a record input port.
|
interface |
ObjectInputField<T>
An object valued field of a record input port.
|
interface |
PeriodInputField
A period valued field of a record input port.
|
interface |
ScalarInputField
A field of a record input port.
|
interface |
StringInputField
A string valued field of a record input port.
|
interface |
TimeInputField
A time valued field of a record input port.
|
interface |
TimestampInputField
A timestamp valued field of a record input port.
|
Modifier and Type | Method and Description |
---|---|
ScalarValued |
ScalarTokenSequence.getToken(int index) |
Modifier and Type | Method and Description |
---|---|
static <T extends ScalarValued> |
TokenUtils.castFields(RecordValued value,
Class<T> clazz,
String[] fieldNames)
Extracts the given list of field names, casting them to
the specified type.
|
static <T extends ScalarValued> |
TokenUtils.castFields(ScalarValued[] fields,
Class<T> clazz)
Casts an array of fields to the specified type
|
Modifier and Type | Method and Description |
---|---|
static <T extends ScalarValued> |
TokenUtils.castFields(RecordValued value,
Class<T> clazz,
String[] fieldNames)
Extracts the given list of field names, casting them to
the specified type.
|
static <T extends ScalarValued> |
TokenUtils.castFields(ScalarValued[] fields,
Class<T> clazz)
Casts an array of fields to the specified type
|
static ScalarValued[] |
TokenUtils.selectFields(RecordValued value,
String[] fieldNames)
Extracts the given list of field values from a record value.
|
Modifier and Type | Method and Description |
---|---|
static <T extends ScalarValued> |
TokenUtils.castFields(ScalarValued[] fields,
Class<T> clazz)
Casts an array of fields to the specified type
|
static int |
TokenUtils.compare(ScalarValued value1,
ScalarValued value2)
Indicates the relative ordering of two scalar values
in ascending order.
|
static RecordTokenComparator |
TokenComparators.getCompositeComparator(ScalarValued[] left,
ScalarValued[] right,
TokenOrder order)
Creates a composite comparator, bound to the given sets of left and right values,
using the specified ordering for all pairings of values.
|
static RecordTokenComparator |
TokenComparators.getCompositeComparator(ScalarValued[] left,
ScalarValued[] right,
TokenOrder order)
Creates a composite comparator, bound to the given sets of left and right values,
using the specified ordering for all pairings of values.
|
static RecordTokenComparator |
TokenComparators.getCompositeComparator(ScalarValued[] left,
ScalarValued[] right,
TokenOrder[] order)
Creates a composite comparator, bound to the given sets of left and right values,
using the specified orderings for each pairing of values.
|
static RecordTokenComparator |
TokenComparators.getCompositeComparator(ScalarValued[] left,
ScalarValued[] right,
TokenOrder[] order)
Creates a composite comparator, bound to the given sets of left and right values,
using the specified orderings for each pairing of values.
|
static ScalarTokenType[] |
TokenUtils.getTypes(ScalarValued[] values)
Extracts the types of an array of scalar token values.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRecordValued<F extends ScalarValued>
For internal use only.
|
Modifier and Type | Method and Description |
---|---|
ScalarValued |
RecordValuedFilter.getField(int index) |
ScalarValued |
RecordValued.getField(int index)
Get the field at the given index within the list of fields.
|
ScalarValued |
RecordMap.RecordMapIterator.getField(int index) |
ScalarValued |
RecordValuedFilter.getField(String fieldName) |
ScalarValued |
RecordValued.getField(String fieldName)
Gets the value of the field with the given name.
|
ScalarValued |
RecordMap.RecordMapIterator.getField(String fieldName) |
ScalarValued[] |
RecordValuedFilter.getFields() |
ScalarValued[] |
RecordValued.getFields()
Gets the values of all fields in the record
|
ScalarValued[] |
RecordMap.RecordMapIterator.getFields() |
F[] |
AbstractRecordValued.getFields() |
Modifier and Type | Method and Description |
---|---|
void |
RecordTokenComparator.setLeftSources(ScalarValued[] sources)
Binds the left-hand values of the comparator to the specified
objects.
|
void |
RecordTokenComparator.setRightSources(ScalarValued[] sources)
Binds the right-hand values of the comparator to the specified
objects.
|
static RecordToken |
RecordToken.wrap(String name,
ScalarValued value)
Create a new record token with a single field with
the specified name and value.
|
Constructor and Description |
---|
AbstractRecordValued(F[] fieldValues,
ModificationCountProvider modificationCountProvider)
Constructs a value using the given elements as the
field elements.
|
AbstractRecordValued(RecordTokenType type,
F[] fieldValues,
boolean validateType,
ModificationCountProvider modificationCountProvider)
Constructs a value using the given elements as the
field elements, using the specified type.
|
AbstractRecordValued(RecordTokenType type,
F[] fieldValues,
ModificationCountProvider modificationCountProvider)
Constructs a value using the given elements as the
field elements, using the specified type.
|
CompositeValue(RecordTokenType type,
ScalarValued[] fields)
Construct a composite with the described schema using
the supplied
ScalarValued objects. |
CompositeValue(RecordTokenType type,
ScalarValued[] fields,
ModificationCountProvider modCountProvider)
Construct a composite with the described schema using
the supplied
ScalarValued objects. |
CompositeValue(ScalarValued[] fields)
Construct a composite from the supplied
ScalarValued objects. |
CompositeValue(ScalarValued[] fields,
ModificationCountProvider modCountProvider)
Construct a composite from the supplied
ScalarValued objects. |
RecordToken(RecordTokenType type,
ScalarValued... fieldValues)
Constructs a new token with the specified field types, using the
field values in the given containers.
|
RecordToken(ScalarValued... fieldValues)
Constructs a new token using the field values in the given containers.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BinaryValued
A
TokenValued object containing a binary value. |
interface |
BooleanValued
A
TokenValued object containing a boolean value. |
interface |
CharValued
A
TokenValued object containing a character value. |
interface |
DateValued
A
TokenValued object containing a date value. |
interface |
DoubleValued
A
TokenValued object containing a double value. |
interface |
DurationValued
A
TokenValued object containing a Duration value. |
interface |
FloatValued
A
TokenValued object containing a float value. |
interface |
IntValued
A
TokenValued object containing an integer value. |
interface |
Ip4AddressValued
A
TokenValued object containing a ip4 address value. |
interface |
Ip6AddressValued
A
TokenValued object containing a ip4 address value. |
interface |
LongValued
A
TokenValued object containing a long value. |
interface |
MoneyValued
A
TokenValued object containing a money value. |
interface |
NumericValued
A
TokenValued object containing a numeric value. |
interface |
ObjectValued<O>
A
TokenValued object containing a Java object. |
interface |
PeriodValued
A
TokenValued object containing a Period value. |
interface |
ScalarRegister
A mutable
ScalarValued object. |
interface |
ScalarToken
An immutable
ScalarValued object. |
interface |
StringValued
A
TokenValued object containing a string value. |
interface |
TimestampValued
A
TokenValued object containing a timestamp value. |
interface |
TimeValued
A
TokenValued object containing a time value. |
Modifier and Type | Class and Description |
---|---|
class |
BinaryRegister
A mutable
BinaryValued object. |
class |
BinaryToken
An immutable
BinaryValued object. |
class |
BooleanRegister
A mutable
BooleanValued object. |
class |
BooleanToken
An immutable
BooleanValued object. |
class |
CharRegister
A mutable
CharValued object. |
class |
CharToken
An immutable
CharValued object. |
class |
DateRegister
A mutable
DateValued object. |
class |
DateToken
An immutable
DateValued object. |
class |
DateTokenConverter
Deprecated.
since 6.1
|
class |
DoubleRegister
A mutable
DoubleValued object. |
class |
DoubleToken
An immutable
DoubleValued object. |
class |
DurationRegister
A mutable
DurationValued object. |
class |
DurationToken
An immutable
DurationValued object. |
class |
FloatRegister
A mutable
BinaryValued object. |
class |
FloatToken
An immutable
FloatValued object. |
class |
IntRegister
A mutable
IntValued object. |
class |
IntToken
An immutable
IntValued object. |
class |
Ip4AddressRegister
A mutable
Ip4AddressValued object. |
class |
Ip4AddressToken
An immutable
Ip4AddressValued object. |
class |
Ip6AddressRegister
A mutable
Ip6AddressValued object. |
class |
Ip6AddressToken
An immutable
Ip6AddressValued object. |
class |
LongRegister
A mutable
IntValued object. |
class |
LongToken
An immutable
LongValued object. |
class |
MoneyRegister
A mutable
MoneyValued object. |
class |
MoneyToken
An immutable
MoneyValued object. |
class |
NullToken
An null token.
|
class |
NumericRegister
A mutable
NumericValued object. |
class |
NumericToken
An immutable
NumericValued object. |
class |
ObjectRegister<O>
A mutable
ObjectValued object. |
class |
ObjectToken<O>
An immutable
ObjectValued object. |
class |
PeriodRegister
A mutable
PeriodValued object. |
class |
PeriodToken
An immutable
PeriodValued object. |
class |
StringRegister
A mutable
StringValued object. |
class |
StringToken
An immutable
StringValued object. |
class |
TimeRegister
A mutable
TimeValued object. |
class |
TimestampRegister
A mutable
TimestampValued object. |
class |
TimestampToken
An immutable
TimestampValued object. |
class |
TimestampTokenConverter
Deprecated.
since 6.1
|
class |
TimeToken
An immutable
TimeValued object. |
Modifier and Type | Method and Description |
---|---|
ScalarValued |
FieldDomain.getLowerBound()
Returns the lower bound of the field or
null if unknown |
ScalarValued |
FieldDomain.getUpperBound()
Returns the upper bound of the field or
null if unknown |
Modifier and Type | Method and Description |
---|---|
Set<ScalarValued> |
FieldDomain.getValues()
Returns the allowed values of the field or
empty if unknown. |
Constructor and Description |
---|
FieldDomain(ScalarValued lowerBound,
ScalarValued upperBound,
Set<? extends ScalarValued> values)
Creates a new field domain
|
Constructor and Description |
---|
FieldDomain(ScalarValued lowerBound,
ScalarValued upperBound,
Set<? extends ScalarValued> values)
Creates a new field domain
|
Copyright © 2019 Actian Corporation. All rights reserved.