Package | Description |
---|---|
com.pervasive.datarush.encoding |
Provides basic interfaces used when converting tokens
into various formats.
|
com.pervasive.datarush.encoding.binary |
Implementations of encoders of tokens
into binary formats.
|
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.ports.physical |
Provides classes and interfaces for accessing and producing the data flowing
between operators in a dataflow graph.
|
com.pervasive.datarush.sequences |
Provides classes and interfaces related to sequences of tokens.
|
com.pervasive.datarush.sequences.record |
Provides implementations of sequences of record valued tokens.
|
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 |
TokenEncoder.setSource(TokenValued source)
Sets the container holding values to be encoded.
|
Modifier and Type | Method and Description |
---|---|
protected TokenValued |
AbstractTokenEncoder.getSource()
Returns the current source held by this encoder.
|
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractTokenEncoder.doSourceUpdated(TokenValued source)
Sets the source buffer for encoding.
|
void |
AbstractTokenEncoder.setSource(TokenValued source)
This implementation sets the source variable and invokes
the method
AbstractTokenEncoder.doSourceUpdated(TokenValued) . |
Modifier and Type | Class and Description |
---|---|
class |
DatasetIterator
Utility for reading a data-set written by
WriteStagingDataset outside of an engine context. |
Modifier and Type | Method and Description |
---|---|
void |
DatasetBuilder.append(TokenValued value) |
void |
DatasetBuilder.append(TokenValued value,
long count) |
Modifier and Type | Method and Description |
---|---|
TokenValued |
DataNotSortedException.getCurrentTValue()
Return the token value where the sort order discrepancy occurred.
|
TokenValued |
DataNotSortedException.getPreviousTValue()
Return the previous token value before the sort order discrepancy
occurred.
|
Modifier and Type | Method and Description |
---|---|
DataNotSortedException |
DataNotSortedException.setCurrentTValue(TokenValued currentTValue)
Internal use only: set the current token value where the sort
order discrepancy occurred.
|
DataNotSortedException |
DataNotSortedException.setPreviousTValue(TokenValued previousTValue)
Internal use only: set the previous token value where the sort
order discrepancy occurred.
|
Constructor and Description |
---|
DataNotSortedException(String prefix,
TokenValued currentTV,
TokenValued previousTV,
int position)
Constructs a
DataNotSortedException . |
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 |
RecordInput
An input port on a record data flow.
|
interface |
ScalarInputField
A field of a record input port.
|
interface |
SteppableRecordValued |
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 |
---|---|
void |
RecordOutput.push(TokenValued value)
Appends the given token value onto the output's flow.
|
void |
RecordOutput.push(TokenValued value,
long n)
Appends the given token value onto the output's flow multiple times.
|
Modifier and Type | Interface and Description |
---|---|
interface |
SeekableTokenValuedIterator
A
TokenValuedIterator that is also seekable. |
interface |
TokenValuedIterator
Iterator over token values.
|
Modifier and Type | Method and Description |
---|---|
TokenValued |
TokenSequence.getToken(int index)
Gets the value at the specified position.
|
Modifier and Type | Method and Description |
---|---|
void |
TokenAppendable.append(TokenValued value)
Appends the specified token value to this sequence.
|
void |
TokenAppendable.append(TokenValued value,
long count)
Appends the specified token value to this sequence
multiple times.
|
int |
TokenSequence.compareElement(int index,
TokenValued value)
Compares the value of the specified token to the token at which
the given port is positioned.
|
void |
MutableTokenSequence.fillValue(int start,
int length,
TokenValued value)
Sets the tokens in the specified subsequence to the given value.
|
void |
MutableTokenSequence.setValue(int index,
TokenValued value)
Sets the token at the specified position to the given value.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CloseableRecordValuedIterator
A record iterator which has resources which need
to be released when being disposed.
|
interface |
RecordValuedIterator
Iterator over record values.
|
interface |
SeekableRecordValuedIterator
A repositionable iterator over record values.
|
Modifier and Type | Method and Description |
---|---|
void |
SparseRecordTokenList.append(TokenValued value) |
void |
RecordTokenList.append(TokenValued value)
Appends the specified token value to this sequence.
|
void |
SparseRecordTokenList.append(TokenValued value,
long count) |
void |
RecordTokenList.append(TokenValued value,
long count)
Appends the specified token value to this sequence
multiple times.
|
int |
SparseRecordTokenList.compareElement(int index,
TokenValued value) |
int |
RecordTokenSequence.compareElement(int index,
TokenValued value)
Compares the values of the specified row of tokens to the
tokens at which the given port is positioned.
|
void |
SparseRecordTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
RecordTokenList.fillValue(int startIndex,
int count,
TokenValued value) |
void |
SparseRecordTokenList.setValue(int index,
TokenValued value) |
void |
RecordTokenList.setValue(int index,
TokenValued value) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractScalarTokenSequence.append(TokenValued in) |
void |
AbstractScalarTokenSequence.append(TokenValued in,
long count) |
int |
AbstractScalarTokenSequence.compareElement(int index,
TokenValued value) |
void |
TimestampTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
TimeTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
StringTokenList.fillValue(int startIndex,
int count,
TokenValued value) |
void |
PeriodTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
ObjectTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
NumericTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
MoneyTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
LongTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
Ip6AddressTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
Ip4AddressTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
IntTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
FloatTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
DurationTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
DoubleTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
DateTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
CharTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
BooleanTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
BinaryTokenList.fillValue(int start,
int length,
TokenValued value) |
void |
TimestampTokenList.setValue(int index,
TokenValued value) |
void |
TimeTokenList.setValue(int index,
TokenValued value) |
void |
StringTokenList.setValue(int position,
TokenValued value) |
void |
PeriodTokenList.setValue(int index,
TokenValued value) |
void |
ObjectTokenList.setValue(int index,
TokenValued value) |
void |
NumericTokenList.setValue(int index,
TokenValued value) |
void |
MoneyTokenList.setValue(int index,
TokenValued value) |
void |
LongTokenList.setValue(int index,
TokenValued value) |
void |
Ip6AddressTokenList.setValue(int index,
TokenValued value) |
void |
Ip4AddressTokenList.setValue(int index,
TokenValued value) |
void |
IntTokenList.setValue(int index,
TokenValued value) |
void |
FloatTokenList.setValue(int index,
TokenValued value) |
void |
DurationTokenList.setValue(int index,
TokenValued value) |
void |
DoubleTokenList.setValue(int index,
TokenValued value) |
void |
DateTokenList.setValue(int index,
TokenValued value) |
void |
CharTokenList.setValue(int index,
TokenValued value) |
void |
BooleanTokenList.setValue(int index,
TokenValued value) |
void |
BinaryTokenList.setValue(int index,
TokenValued value) |
Modifier and Type | Interface and Description |
---|---|
interface |
DataRegister
A mutable
TokenValued object. |
interface |
DataToken
An immutable
TokenValued object. |
Modifier and Type | Method and Description |
---|---|
static TokenValued |
TokenUtils.getNull(TokenType type)
Returns an appropriate null value for the given type.
|
Modifier and Type | Method and Description |
---|---|
static String |
TokenUtils.asString(TokenValued value)
Formats a token value as a string suitable for output.
|
static DataToken |
TokenUtils.asToken(TokenValued value)
Creates an immutable copy of the given token value.
|
static TokenComparator |
TokenComparators.getComparator(TokenValued left,
TokenValued right)
Creates a comparator, bound to the given left and right values.
|
static TokenConverter |
TokenConverters.getConverter(TokenValued value)
Creates a converter, bound to the given value
|
void |
TokenSettable.set(TokenValued value)
Sets the contained value to the given token value.
|
void |
TokenComparator.setLeftSource(TokenValued source)
Binds the left-hand value of the comparator to the specified
object.
|
void |
TokenComparator.setRightSource(TokenValued source)
Binds the right-hand value of the comparator to the specified
object.
|
void |
TokenConverter.setSource(TokenValued value)
Sets the source value for this converter.
|
static void |
TokenUtils.transfer(TokenValued[] sources,
TokenSettable[] dest)
Transfers the given array of sources to the array of destinations by-position.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RecordValued
A
TokenValued object containing record data. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRecordValued<F extends ScalarValued>
For internal use only.
|
class |
CompositeValue
A composite value comprised of scalar valued fields.
|
class |
RecordMap.RecordMapIterator
An iterator capable of providing access to a subset of records within
the record map's cache.
|
class |
RecordRegister
A composite register of scalar registers; a mutable
RecordValued object. |
class |
RecordToken
A composite token of scalar valued tokens; an immutable
RecordValued object. |
class |
RecordValuedFilter
An adapter for converting the apparent type of a
RecordValued . |
class |
SparseRecordRegister
A composite register of scalar registers; a mutable
RecordValued object. |
Modifier and Type | Method and Description |
---|---|
void |
RecordMap.Builder.append(TokenValued value) |
void |
RecordMap.Builder.append(TokenValued value,
long count) |
void |
SparseRecordRegister.set(TokenValued value) |
void |
RecordSettableFilter.set(TokenValued value)
Sets the contained value to the given token value.
|
void |
RecordRegisterSupport.set(TokenValued value) |
void |
RecordRegister.set(TokenValued value) |
void |
MutableComposite.set(TokenValued value) |
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 |
ScalarValued
A
TokenValued object containing a scalar value. |
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 |
---|---|
void |
TimestampRegister.set(TokenValued value) |
void |
TimeRegister.set(TokenValued value) |
void |
StringRegister.set(TokenValued value) |
void |
PeriodRegister.set(TokenValued value) |
void |
ObjectRegister.set(TokenValued value) |
void |
NumericRegister.set(TokenValued value) |
void |
MoneyRegister.set(TokenValued value) |
void |
LongRegister.set(TokenValued value) |
void |
Ip6AddressRegister.set(TokenValued value) |
void |
Ip4AddressRegister.set(TokenValued value) |
void |
IntRegister.set(TokenValued value) |
void |
FloatRegister.set(TokenValued value) |
void |
DurationRegister.set(TokenValued value) |
void |
DoubleRegister.set(TokenValued value) |
void |
DateRegister.set(TokenValued value) |
void |
CharRegister.set(TokenValued value) |
void |
BooleanRegister.set(TokenValued value) |
void |
BinaryRegister.set(TokenValued value) |
Constructor and Description |
---|
TokenValueExtractor(TokenValued token) |
Copyright © 2021 Actian Corporation. All rights reserved.