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)
org.joda.time.DateTime	getEnd()
long	getFileSize()
protected TSD_Impl	getTSData()
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

evaluate, evaluate, evaluate, getContext, getContext, getContext

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