com.groupon.lex.metrics.history.xdr.support

Class SequenceTSData

java.lang.Object

com.groupon.lex.metrics.history.xdr.support.SequenceTSData

All Implemented Interfaces:

CollectHistory, TSData, Iterable<TimeSeriesCollection>, Collection<TimeSeriesCollection>

Direct Known Subclasses:

ReadonlyTableFile, RWListFile, TSDataFileChain, UnmappedReadonlyTSDataFile

public abstract class SequenceTSData
extends Object
implements TSData

A TSData that is based around sequences.

Author:

ariane

Nested Class Summary

Nested classes/interfaces inherited from interface com.groupon.lex.metrics.history.CollectHistory

CollectHistory.ApplyExpressions, CollectHistory.NamedEvaluation

Constructor Summary

Constructors

Constructor and Description
SequenceTSData()

Method Summary

Modifier and Type	Method and Description
boolean	contains(Object o) Test if the TSData contains the given value.
boolean	containsAll(Collection<?> c) Test if the TSData contains all the given values.
Compression	getAppendCompression() Get the compression used for append files.
Compression	getOptimizedCompression() Get the compression used for optimized files.
abstract com.groupon.lex.metrics.lib.sequence.ObjectSequence<TimeSeriesCollection>	getSequence()
boolean	isEmpty() Test if the TSData is empty.
Iterator<TimeSeriesCollection>	iterator() Returns an iterator for this TSData.
Stream<TimeSeriesCollection>	parallelStream()
void	setAppendCompression(Compression compression) Set the compression used for append files.
void	setOptimizedCompression(Compression compression) Set the compression used for optimized files.
int	size() Returns the number of entries in the TSData.
Spliterator<TimeSeriesCollection>	spliterator() Returns an iterator for this TSData.
Stream<TimeSeriesCollection>	stream() Stream the TSData contents.
Stream<TimeSeriesCollection>	stream(org.joda.time.DateTime begin)
Stream<TimeSeriesCollection>	stream(org.joda.time.DateTime begin, org.joda.time.DateTime end)
Stream<TimeSeriesCollection>	streamReversed() Stream the TSData contents in reverse chronological order.
Object[]	toArray()
<T> T[]	toArray(T[] a)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.groupon.lex.metrics.history.TSData

add, addAll, asColumnMajorTSData, canAddSingleRecord, clear, getBegin, getEnd, getFileChannel, getFileSize, getMajor, getMinor, isOptimized, readonly, remove, removeAll, removeIf, retainAll

Methods inherited from interface java.util.Collection

equals, hashCode

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface com.groupon.lex.metrics.history.CollectHistory

addAll, evaluate, evaluate, evaluate, getContext, getContext, getContext, stream, stream, stream, streamGroup

Constructor Detail

SequenceTSData

public SequenceTSData()

Method Detail

getSequence

public abstract com.groupon.lex.metrics.lib.sequence.ObjectSequence<TimeSeriesCollection> getSequence()

iterator

public Iterator<TimeSeriesCollection> iterator()

Description copied from interface: TSData

Returns an iterator for this TSData. Iterator is always ordered, without duplicate timestamps.

Specified by:

iterator in interface TSData

Specified by:

iterator in interface Iterable<TimeSeriesCollection>

Specified by:

iterator in interface Collection<TimeSeriesCollection>

spliterator

public Spliterator<TimeSeriesCollection> spliterator()

Description copied from interface: TSData

Returns an iterator for this TSData. Iterator is always ordered, without duplicate timestamps.

Specified by:

spliterator in interface TSData

Specified by:

spliterator in interface Iterable<TimeSeriesCollection>

Specified by:

spliterator in interface Collection<TimeSeriesCollection>

stream

public Stream<TimeSeriesCollection> stream()

Description copied from interface: TSData

Stream the TSData contents. The stream iterates collection in chronological order, without duplicate timestamps.

Specified by:

stream in interface CollectHistory

Specified by:

stream in interface TSData

Specified by:

stream in interface Collection<TimeSeriesCollection>

parallelStream

public Stream<TimeSeriesCollection> parallelStream()

Specified by:

parallelStream in interface Collection<TimeSeriesCollection>

streamReversed

public Stream<TimeSeriesCollection> streamReversed()

Description copied from interface: TSData

Stream the TSData contents in reverse chronological order. The stream iterates collection in reverse chronological order, without duplicate timestamps.

Specified by:

streamReversed in interface CollectHistory

Specified by:

streamReversed in interface TSData

isEmpty

public boolean isEmpty()

Description copied from interface: TSData

Test if the TSData is empty.

Specified by:

isEmpty in interface TSData

Specified by:

isEmpty in interface Collection<TimeSeriesCollection>

size

public int size()

Description copied from interface: TSData

Returns the number of entries in the TSData.

Specified by:

size in interface TSData

Specified by:

size in interface Collection<TimeSeriesCollection>

toArray

public Object[] toArray()

Specified by:

toArray in interface TSData

Specified by:

toArray in interface Collection<TimeSeriesCollection>

toArray

public <T> T[] toArray(T[] a)

Specified by:

toArray in interface TSData

Specified by:

toArray in interface Collection<TimeSeriesCollection>

stream

public Stream<TimeSeriesCollection> stream(org.joda.time.DateTime begin)

Specified by:

stream in interface CollectHistory

stream

public Stream<TimeSeriesCollection> stream(org.joda.time.DateTime begin,
                                           org.joda.time.DateTime end)

Specified by:

stream in interface CollectHistory

contains

public boolean contains(Object o)

Description copied from interface: TSData

Test if the TSData contains the given value.

Specified by:

contains in interface TSData

Specified by:

contains in interface Collection<TimeSeriesCollection>

containsAll

public boolean containsAll(Collection<?> c)

Description copied from interface: TSData

Test if the TSData contains all the given values.

Specified by:

containsAll in interface TSData

Specified by:

containsAll in interface Collection<TimeSeriesCollection>

getAppendCompression

public Compression getAppendCompression()

Description copied from interface: TSData

Get the compression used for append files.

Specified by:

getAppendCompression in interface TSData

Returns:

The compression used for append files.

setAppendCompression

public void setAppendCompression(Compression compression)

Description copied from interface: TSData

Set the compression used for append files.

Specified by:

setAppendCompression in interface TSData

Parameters:

compression - The compression used for append files.

getOptimizedCompression

public Compression getOptimizedCompression()

Description copied from interface: TSData

Get the compression used for optimized files.

Specified by:

getOptimizedCompression in interface TSData

Returns:

The compression used for optimized files.

setOptimizedCompression

public void setOptimizedCompression(Compression compression)

Description copied from interface: TSData

Set the compression used for optimized files.

Specified by:

setOptimizedCompression in interface TSData

Parameters:

compression - The compression used for optimized files.