Module datarush.library

Package com.pervasive.datarush.sequences.scalar

Class SparseTimestampTokenList

java.lang.Object

com.pervasive.datarush.sequences.scalar.SparseTimestampTokenList

All Implemented Interfaces:

MutableTokenSequence, MutableScalarTokenSequence, MutableTimestampTokenSequence, ScalarTokenAppendable, ScalarTokenSequence, TimestampTokenSequence, TokenAppendable, TokenSequence, ScalarTyped, TokenTyped

public final class SparseTimestampTokenList
extends Object
implements MutableTimestampTokenSequence

An implementation of MutableTimestampTokenSequence which stores data sparsely. That is, zero values are not stored. This is a much more efficient mechanism when the majority of values are zero.

Constructor Summary

Constructors

Constructor	Description
SparseTimestampTokenList(int initialCapacity)	Creates a new empty list.

Method Summary

Modifier and Type	Method	Description
void	append(TokenSequence data)	Appends all tokens in the specified sequence to this sequence.
void	append(TokenSequence data, int start, int length)	Appends a subsequence of tokens in the specified sequence to this sequence.
void	append(TokenValued value)	Appends the specified token value to this sequence.
void	append(TokenValued value, long count)	Appends the specified token value to this sequence multiple times.
void	append(Timestamp value)	Appends the specified timestamp to this sequence.
void	append(Timestamp value, int count)	Appends the specified timestamp to this sequence multiple times.
void	appendEpochTime(long epochSeconds, int subsecondNanos, int offsetSeconds)	Appends the timestamp specified in epoch time to this sequence.
void	appendEpochTime(long epochSeconds, int subsecondNanos, int offsetSeconds, int count)	Appends the timestamp specified in epoch time to this sequence multiple times.
void	appendNull()	Append a null value to this sequence.
void	appendNull(int count)	Append a null value to this sequence.
void	appendZero()	Appends a zero value to this sequence.
void	appendZero(int count)	Appends the specified number of zero values to this sequence.
int	compareElement(int absoluteIndex, TokenValued value)	Compares the value of the specified token to the token at which the given port is positioned.
int	compareElements(int lhsAbsoluteIndex, int rhsAbsoluteIndex)	Compares the values of the tokens at the specified positions.
void	ensureCanonical()	Ensures that the internal representation is in a canonical form such that it can be read safely by multiple threads.
void	fillValue(int start, int length, TokenValued value)	Sets the tokens in the specified subsequence to the given value.
ElementComparator	getElementComparator(TokenOrder sortOrder)	Gets an ElementComparator for this sequence using the specified ordering.
long	getEpochSeconds(int index)	Gets the value of the specified token as the number of seconds elapsed since January 1, 1970 00:00:00 GMT.
long	getModificationCount()	Returns the current modification count.
int	getOffsetSeconds(int index)	Gets the time zone plus daylight savings time offset (in seconds) of the timestamp value of the specified token.
int	getSubsecondNanos(int index)	Gets the subsecond portion (in nanoseconds) of the timestamp value of the specified token.
Timestamp	getTimestamp(int index)	Gets the value of the specified token as a timestamp.
TimestampValued	getToken(int index)	Gets the value at the specified position.
TimestampSettable	getTokenSetter(int index)	Returns a mutator for the given index.
ScalarTokenType	getType()	Gets the data type of the tokens in the sequence.
void	getValues(int start, long[] secValues, int[] nanoValues, int[] offsetValues, boolean[] nulls, int offset, int length)	Gets the values and null indicators for a range of tokens.
int	hashCode(int absoluteIndex)	Gets the hash code for the token at the specified position.
boolean	isNull()	Returns whether all elements are null.
boolean	isNull(int absoluteIndex)	Indicates whether the specified token has a null value.
boolean	isZero(int absoluteIndex)	Indicates whether the specified token has a zero value.
TimestampValuedIterator	newValueIterator()	Creates an iterator over the non-null values of this sequence.
void	reset()	Removes all elements from the sequence.
void	setEpochSeconds(int absoluteIndex, long seconds, int nanos, int offsetSeconds)	Sets the token at the specified position to the given value.
void	setNull(int absoluteIndex)	Sets the token at the specified position to be null valued.
void	setNull(int start, int length)	Sets the tokens in the specified subsequence to be null valued.
void	setValue(int absoluteIndex, TokenValued value)	Sets the token at the specified position to the given value.
void	setValues(int start, TokenSequence values, int offset, int length)	Sets the tokens in the specified subsequence of the array to the corresponding values from a subsequence of the given source sequence.
void	setZero(int absoluteIndex)	Sets the token at the specified position to be zero valued.
void	setZero(int start, int length)	Sets the tokens in the specified subsequence to be zero valued.
int	size()	Gets the length of the sequence.
String	toString()
String	toString(int absoluteIndex)	Gets the string representation of the token at the specified position.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.pervasive.datarush.sequences.scalar.MutableScalarTokenSequence

ensureCanonical, getModificationCount

Methods inherited from interface com.pervasive.datarush.sequences.MutableTokenSequence

appendNull, appendNull, appendZero, appendZero, fillValue, reset, setNull, setNull, setValue, setValues, setZero, setZero

Methods inherited from interface com.pervasive.datarush.sequences.scalar.ScalarTokenSequence

getType, isNull, isZero

Methods inherited from interface com.pervasive.datarush.sequences.TokenAppendable

append, append, append, append

Methods inherited from interface com.pervasive.datarush.sequences.TokenSequence

compareElement, compareElements, getElementComparator, hashCode, isNull, size, toString

Constructor Detail

SparseTimestampTokenList

public SparseTimestampTokenList(int initialCapacity)

Creates a new empty list.

Parameters:

initialCapacity - initial storage capacity of the list

Method Detail

append

public void append(Timestamp value)

Description copied from interface: MutableTimestampTokenSequence

Appends the specified timestamp to this sequence.

Specified by:

append in interface MutableTimestampTokenSequence

Parameters:

value - the value to append. If null, this is equivalent to appendNull().

append

public void append(Timestamp value,
                   int count)

Description copied from interface: MutableTimestampTokenSequence

Appends the specified timestamp to this sequence multiple times.

Specified by:

append in interface MutableTimestampTokenSequence

Parameters:

value - the value to append. If null, this is equivalent to appendNull().

count - the number of copies to append.

appendEpochTime

public void appendEpochTime(long epochSeconds,
                            int subsecondNanos,
                            int offsetSeconds)

Description copied from interface: MutableTimestampTokenSequence

Appends the timestamp specified in epoch time to this sequence.

Specified by:

appendEpochTime in interface MutableTimestampTokenSequence

Parameters:

epochSeconds - the number of seconds elapsed since January 1, 1970 00:00:00 GMT.

subsecondNanos - the subsecond portion of the timestamp in nanoseconds.

offsetSeconds - the offset in seconds, including both time zone and daylight savings adjustments, from GMT.

appendEpochTime

public void appendEpochTime(long epochSeconds,
                            int subsecondNanos,
                            int offsetSeconds,
                            int count)

Description copied from interface: MutableTimestampTokenSequence

Appends the timestamp specified in epoch time to this sequence multiple times.

Specified by:

appendEpochTime in interface MutableTimestampTokenSequence

Parameters:

epochSeconds - the number of seconds elapsed since January 1, 1970 00:00:00 GMT.

subsecondNanos - the subsecond portion of the timestamp in nanoseconds.

offsetSeconds - the offset in seconds, including both time zone and daylight savings adjustments, from GMT.

count - the number of copies to append.

setEpochSeconds

public void setEpochSeconds(int absoluteIndex,
                            long seconds,
                            int nanos,
                            int offsetSeconds)

Description copied from interface: MutableTimestampTokenSequence

Sets the token at the specified position to the given value.

Specified by:

setEpochSeconds in interface MutableTimestampTokenSequence

Parameters:

absoluteIndex - the position to modify

seconds - the number of seconds elapsed since January 1, 1970 00:00:00 GMT.

nanos - the subsecond portion of the timestamp in nanoseconds.

offsetSeconds - the offset in seconds, including both time zone and daylight savings adjustments, from GMT.

getTimestamp

public Timestamp getTimestamp(int index)

Description copied from interface: TimestampTokenSequence

Gets the value of the specified token as a timestamp.

Specified by:

getTimestamp in interface TimestampTokenSequence

Parameters:

index - the position of the token in the sequence

Returns:

the value of the token. If the token is null valued, null is returned.

getEpochSeconds

public long getEpochSeconds(int index)

Description copied from interface: TimestampTokenSequence

Gets the value of the specified token as the number of seconds elapsed since January 1, 1970 00:00:00 GMT.

Specified by:

getEpochSeconds in interface TimestampTokenSequence

Parameters:

index - the position of the token in the sequence

Returns:

the value of the token. If the token is null valued, 0 is returned.

getOffsetSeconds

public int getOffsetSeconds(int index)

Description copied from interface: TimestampTokenSequence

Gets the time zone plus daylight savings time offset (in seconds) of the timestamp value of the specified token.

Specified by:

getOffsetSeconds in interface TimestampTokenSequence

Parameters:

index - the position of the token in the sequence

Returns:

the time zone plus daylight savings time offset in seconds. If the token is null valued, 0 is returned.

getSubsecondNanos

public int getSubsecondNanos(int index)

Description copied from interface: TimestampTokenSequence

Gets the subsecond portion (in nanoseconds) of the timestamp value of the specified token.

Specified by:

getSubsecondNanos in interface TimestampTokenSequence

Parameters:

index - the position of the token in the sequence

Returns:

the subsecond portion of the value in nanoseconds. If the token is null valued, 0 is returned.

getToken

public TimestampValued getToken(int index)

Description copied from interface: TokenSequence

Gets the value at the specified position.

Specified by:

getToken in interface ScalarTokenSequence

Specified by:

getToken in interface TimestampTokenSequence

Specified by:

getToken in interface TokenSequence

Parameters:

index - the index of the token

Returns:

the value

getTokenSetter

public TimestampSettable getTokenSetter(int index)

Description copied from interface: MutableTokenSequence

Returns a mutator for the given index.

Specified by:

getTokenSetter in interface MutableScalarTokenSequence

Specified by:

getTokenSetter in interface MutableTimestampTokenSequence

Specified by:

getTokenSetter in interface MutableTokenSequence

Parameters:

index - the position

Returns:

a mutator for the given index.

getValues

public void getValues(int start,
                      long[] secValues,
                      int[] nanoValues,
                      int[] offsetValues,
                      boolean[] nulls,
                      int offset,
                      int length)

Description copied from interface: TimestampTokenSequence

Gets the values and null indicators for a range of tokens.

Specified by:

getValues in interface TimestampTokenSequence

Parameters:

start - the starting index of the range

secValues - an array into which to place the epoch second values of elements

nanoValues - an array into which to place the subsecond values of elements

offsetValues - an array into which to place the offset seconds values of elements

nulls - an array into which to place null indicator values

offset - the starting offset into the target arrays. That is, elements[offset] and nulls[offset] will get the value and null indicator respectively of the token at position start, and so on.

length - number of tokens to get

newValueIterator

public TimestampValuedIterator newValueIterator()

Description copied from interface: TokenSequence

Creates an iterator over the non-null values of this sequence. The iterator will automatically be reset as modifications are made to the sequence.

Specified by:

newValueIterator in interface ScalarTokenSequence

Specified by:

newValueIterator in interface TimestampTokenSequence

Specified by:

newValueIterator in interface TokenSequence

Returns:

an newly-created iterator over the non-null values of this sequence.

isNull

public final boolean isNull()

Description copied from interface: ScalarTokenSequence

Returns whether all elements are null.

Specified by:

isNull in interface ScalarTokenSequence

Returns:

whether all elements are null.

getModificationCount

public final long getModificationCount()

Description copied from interface: MutableScalarTokenSequence

Returns the current modification count. Modification count must be strictly increasing.

Specified by:

getModificationCount in interface MutableScalarTokenSequence

Returns:

the current change sequence number

size

public final int size()

Description copied from interface: TokenSequence

Gets the length of the sequence.

Specified by:

size in interface TokenSequence

Returns:

the number of tokens in the sequence.

setZero

public final void setZero(int absoluteIndex)

Description copied from interface: MutableTokenSequence

Sets the token at the specified position to be zero valued.

Specified by:

setZero in interface MutableTokenSequence

Parameters:

absoluteIndex - the position of the token in the array

setZero

public void setZero(int start,
                    int length)

Description copied from interface: MutableTokenSequence

Sets the tokens in the specified subsequence to be zero valued.

Specified by:

setZero in interface MutableTokenSequence

Parameters:

start - the starting index of the subsequence in the array

length - the length of the subsequence

setNull

public final void setNull(int absoluteIndex)

Description copied from interface: MutableTokenSequence

Sets the token at the specified position to be null valued.

Specified by:

setNull in interface MutableTokenSequence

Parameters:

absoluteIndex - the position of the token in the array

setNull

public final void setNull(int start,
                          int length)

Description copied from interface: MutableTokenSequence

Sets the tokens in the specified subsequence to be null valued.

Specified by:

setNull in interface MutableTokenSequence

Parameters:

start - the starting index of the subsequence in the array

length - the length of the subsequence

getType

public ScalarTokenType getType()

Description copied from interface: ScalarTokenSequence

Gets the data type of the tokens in the sequence.

Specified by:

getType in interface ScalarTokenSequence

Specified by:

getType in interface ScalarTyped

Specified by:

getType in interface TokenTyped

Returns:

the token data type

isNull

public final boolean isNull(int absoluteIndex)

Description copied from interface: TokenSequence

Indicates whether the specified token has a null value.

Specified by:

isNull in interface TokenSequence

Parameters:

absoluteIndex - the index of the token

Returns:

true if the element is null, false otherwise

isZero

public final boolean isZero(int absoluteIndex)

Description copied from interface: ScalarTokenSequence

Indicates whether the specified token has a zero value.

Specified by:

isZero in interface ScalarTokenSequence

Parameters:

absoluteIndex - the index of the token

Returns:

true if the element is zero, false otherwise

compareElement

public final int compareElement(int absoluteIndex,
                                TokenValued value)

Description copied from interface: TokenSequence

Compares the value of the specified token to the token at which the given port is positioned.

Specified by:

compareElement in interface TokenSequence

Parameters:

absoluteIndex - the index of the token

value - the input port positioned at the token for comparison

Returns:

0 if the values are equal, 1 if the sequence token value is greater, -1 if the sequence token value is lesser. A null value is greater than any other non-null; two null values compare as equal.

compareElements

public final int compareElements(int lhsAbsoluteIndex,
                                 int rhsAbsoluteIndex)

Description copied from interface: TokenSequence

Compares the values of the tokens at the specified positions.

Specified by:

compareElements in interface TokenSequence

Parameters:

lhsAbsoluteIndex - the index of the left-hand element

rhsAbsoluteIndex - the index of the right-hand element

Returns:

0 if the values are equal, 1 if the left hand value is greater, -1 if the left hand value is lesser. A null value is greater than any other non-null; two null values compare as equal.

getElementComparator

public final ElementComparator getElementComparator(TokenOrder sortOrder)

Description copied from interface: TokenSequence

Gets an ElementComparator for this sequence using the specified ordering.

Specified by:

getElementComparator in interface TokenSequence

Parameters:

sortOrder - the desired ordering

Returns:

an ElementComparator for this sequence.

hashCode

public final int hashCode(int absoluteIndex)

Description copied from interface: TokenSequence

Gets the hash code for the token at the specified position.

Specified by:

hashCode in interface TokenSequence

Parameters:

absoluteIndex - the index of the token

Returns:

the hash code for the token

toString

public final String toString()

Overrides:

toString in class Object

toString

public final String toString(int absoluteIndex)

Description copied from interface: TokenSequence

Gets the string representation of the token at the specified position.

Specified by:

toString in interface TokenSequence

Parameters:

absoluteIndex - the index of the token

Returns:

the string representation of the token

appendNull

public final void appendNull()

Append a null value to this sequence.

Specified by:

appendNull in interface MutableTokenSequence

appendNull

public final void appendNull(int count)

Append a null value to this sequence.

Specified by:

appendNull in interface MutableTokenSequence

Parameters:

count - the number of null values to append

appendZero

public final void appendZero()

Description copied from interface: MutableTokenSequence

Appends a zero value to this sequence.

Specified by:

appendZero in interface MutableTokenSequence

appendZero

public void appendZero(int count)

Description copied from interface: MutableTokenSequence

Appends the specified number of zero values to this sequence.

Specified by:

appendZero in interface MutableTokenSequence

Parameters:

count - the number of zero values to append

reset

public final void reset()

Description copied from interface: MutableTokenSequence

Removes all elements from the sequence.

Specified by:

reset in interface MutableTokenSequence

append

public final void append(TokenValued value)

Description copied from interface: TokenAppendable

Appends the specified token value to this sequence.

The data types of the sequence and the value must be compatible. If the types are not identical, appropriate coercion will be attempted.

Specified by:

append in interface TokenAppendable

Parameters:

value - the token value to append

append

public final void append(TokenValued value,
                         long count)

Description copied from interface: TokenAppendable

Appends the specified token value to this sequence multiple times.

The data types of the sequence and the value must be compatible. If the types are not identical, appropriate coercion will be attempted.

Specified by:

append in interface TokenAppendable

Parameters:

value - the token value to append

count - the number of copies to append

setValue

public final void setValue(int absoluteIndex,
                           TokenValued value)

Description copied from interface: MutableTokenSequence

Sets the token at the specified position to the given value.

Specified by:

setValue in interface MutableTokenSequence

Parameters:

absoluteIndex - the position of the token in the array

value - the value to which to set the token. This value must be of an appropriate type for the array.

fillValue

public final void fillValue(int start,
                            int length,
                            TokenValued value)

Description copied from interface: MutableTokenSequence

Sets the tokens in the specified subsequence to the given value.

Specified by:

fillValue in interface MutableTokenSequence

Parameters:

start - the starting index of the subsequence in the array

length - the length of the subsequence

value - the value to which to set the tokens. This value must be of an appropriate type for the array

setValues

public final void setValues(int start,
                            TokenSequence values,
                            int offset,
                            int length)

Description copied from interface: MutableTokenSequence

Sets the tokens in the specified subsequence of the array to the corresponding values from a subsequence of the given source sequence.

Specified by:

setValues in interface MutableTokenSequence

Parameters:

start - the starting index of the subsequence in the array

values - the source sequence. This sequence must be of an appropriate type for the array.

offset - the starting index in the source sequence. Corresponding values will be taken relative to this position. That is, the value of the token at position offset in values will be assigned to the token at position start, and so on.

length - the number of tokens to copy

append

public final void append(TokenSequence data)

Description copied from interface: TokenAppendable

Appends all tokens in the specified sequence to this sequence.

The data types of the sequences must be compatible. If not identical, appropriate coercion will be attempted.

Specified by:

append in interface TokenAppendable

Parameters:

data - the sequence to append

append

public final void append(TokenSequence data,
                         int start,
                         int length)

Description copied from interface: TokenAppendable

Appends a subsequence of tokens in the specified sequence to this sequence.

The data types of the sequences must be compatible. If not identical, appropriate coercion will be attempted.

Specified by:

append in interface TokenAppendable

Parameters:

data - the sequence containing tokens to append

start - the starting index of the subsequence in the source

length - the length of the subsequence

ensureCanonical

public final void ensureCanonical()

Description copied from interface: MutableScalarTokenSequence

Ensures that the internal representation is in a canonical form such that it can be read safely by multiple threads.

Specified by:

ensureCanonical in interface MutableScalarTokenSequence