com.groupon.lex.metrics.history

Class AbstractCollectHistory<TSD_Impl extends TSData>

java.lang.Object

com.groupon.lex.metrics.history.AbstractCollectHistory<TSD_Impl>

All Implemented Interfaces:

CollectHistory

Direct Known Subclasses:

DirCollectHistory

public abstract class AbstractCollectHistory<TSD_Impl extends TSData>
extends Object
implements CollectHistory

Author:

ariane

Nested Class Summary

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

CollectHistory.ApplyExpressions, CollectHistory.NamedEvaluation

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractCollectHistory(TSD_Impl initial)

Method Summary

Modifier and Type	Method and Description
boolean	add(TimeSeriesCollection tsv)
boolean	addAll(Collection<? extends TimeSeriesCollection> c)
Compression	getAppendCompression() Get the compression used for append files.
org.joda.time.DateTime	getEnd()
long	getFileSize()
Compression	getOptimizedCompression() Get the compression used for optimized files.
protected TSD_Impl	getTSData()
void	setAppendCompression(Compression compression) Set the compression used for append files.
void	setOptimizedCompression(Compression compression) Set the compression used for optimized files.
Stream<TimeSeriesCollection>	stream()
Stream<TimeSeriesCollection>	stream(org.joda.time.DateTime begin)
Stream<TimeSeriesCollection>	stream(org.joda.time.DateTime begin, org.joda.time.DateTime end)
Stream<TimeSeriesCollection>	stream(org.joda.time.DateTime begin, org.joda.time.DateTime end, org.joda.time.Duration stepsize)
Stream<TimeSeriesCollection>	stream(org.joda.time.DateTime begin, org.joda.time.Duration stepsize)
Stream<TimeSeriesCollection>	stream(org.joda.time.Duration stepsize)
Stream<TimeSeriesCollection>	streamReversed()

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.CollectHistory

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

Constructor Detail

AbstractCollectHistory

protected AbstractCollectHistory(TSD_Impl initial)

Method Detail

getEnd

public org.joda.time.DateTime getEnd()

Specified by:

getEnd in interface CollectHistory

getTSData

protected final TSD_Impl getTSData()

stream

public Stream<TimeSeriesCollection> stream()

Specified by:

stream in interface CollectHistory

streamReversed

public Stream<TimeSeriesCollection> streamReversed()

Specified by:

streamReversed in interface CollectHistory

stream

public Stream<TimeSeriesCollection> stream(org.joda.time.Duration stepsize)

Specified by:

stream in interface CollectHistory

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.Duration stepsize)

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

stream

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

Specified by:

stream in interface CollectHistory

add

public boolean add(TimeSeriesCollection tsv)

Specified by:

add in interface CollectHistory

addAll

public boolean addAll(Collection<? extends TimeSeriesCollection> c)

Specified by:

addAll in interface CollectHistory

getFileSize

public long getFileSize()

Specified by:

getFileSize in interface CollectHistory

getAppendCompression

public Compression getAppendCompression()

Get the compression used for append files.

Returns:

The compression used for append files.

setAppendCompression

public void setAppendCompression(@NonNull
                                 Compression compression)

Set the compression used for append files.

Parameters:

compression - The compression used for append files.

getOptimizedCompression

public Compression getOptimizedCompression()

Get the compression used for optimized files.

Returns:

The compression used for optimized files.

setOptimizedCompression

public void setOptimizedCompression(@NonNull
                                    Compression compression)

Set the compression used for optimized files.

Parameters:

compression - The compression used for optimized files.