com.groupon.lex.metrics.history.xdr

Class DirCollectHistory

java.lang.Object

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

com.groupon.lex.metrics.history.xdr.DirCollectHistory

All Implemented Interfaces:

CollectHistory

public class DirCollectHistory
extends AbstractCollectHistory<TSDataFileChain>

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
DirCollectHistory(Path dir)
DirCollectHistory(Path dir, long disk_usage_limit)
DirCollectHistory(Path dir, long disk_usage_limit, long max_filesize)
DirCollectHistory(Path dir, Optional<Long> disk_usage_limit, Optional<Long> max_filesize)

Method Summary

Modifier and Type	Method and Description
boolean	add(TimeSeriesCollection tsv)
boolean	addAll(Collection<? extends TimeSeriesCollection> tsv)
TSDataFileChain.BatchAdd	bachAdd()
protected void	ensureDiskUsageBelow(long bytes)
Collection<? extends Collection<TimeSeriesCollection>>	getRawCollections()
boolean	hasPendingTasks()
void	optimizeOldFiles()
protected void	removeKey(TSDataFileChain.Key key)
protected Optional<TSDataFileChain.Key>	selectOldestKey()
void	waitPendingTasks()

Methods inherited from class com.groupon.lex.metrics.history.AbstractCollectHistory

getAppendCompression, getEnd, getFileSize, getOptimizedCompression, getTSData, setAppendCompression, setOptimizedCompression, stream, stream, stream, stream, stream, stream, 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

DirCollectHistory

public DirCollectHistory(Path dir,
                         Optional<Long> disk_usage_limit,
                         Optional<Long> max_filesize)
                  throws IOException

Throws:

IOException

DirCollectHistory

public DirCollectHistory(Path dir)
                  throws IOException

Throws:

IOException

DirCollectHistory

public DirCollectHistory(Path dir,
                         long disk_usage_limit)
                  throws IOException

Throws:

IOException

DirCollectHistory

public DirCollectHistory(Path dir,
                         long disk_usage_limit,
                         long max_filesize)
                  throws IOException

Throws:

IOException

Method Detail

hasPendingTasks

public boolean hasPendingTasks()

waitPendingTasks

public void waitPendingTasks()

selectOldestKey

protected Optional<TSDataFileChain.Key> selectOldestKey()

removeKey

protected void removeKey(TSDataFileChain.Key key)

ensureDiskUsageBelow

protected void ensureDiskUsageBelow(long bytes)

add

public boolean add(TimeSeriesCollection tsv)

Specified by:

add in interface CollectHistory

Overrides:

add in class AbstractCollectHistory<TSDataFileChain>

addAll

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

Specified by:

addAll in interface CollectHistory

Overrides:

addAll in class AbstractCollectHistory<TSDataFileChain>

optimizeOldFiles

public void optimizeOldFiles()

getRawCollections

public Collection<? extends Collection<TimeSeriesCollection>> getRawCollections()

bachAdd

public TSDataFileChain.BatchAdd bachAdd()