com.groupon.lex.metrics.history.xdr

Class UnmappedReadonlyTSDataFile

java.lang.Object

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

com.groupon.lex.metrics.history.xdr.UnmappedReadonlyTSDataFile

All Implemented Interfaces:

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

public final class UnmappedReadonlyTSDataFile
extends SequenceTSData

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
UnmappedReadonlyTSDataFile(GCCloseable<FileChannel> fd)

Method Summary

Modifier and Type	Method and Description
boolean	add(TimeSeriesCollection tsv)
boolean	canAddSingleRecord() Returns true if the file is suitable for adding single records at a time.
org.joda.time.DateTime	getBegin() Get the lowest timestamp covered by this TSData series.
org.joda.time.DateTime	getEnd() Get the highest timestamp covered by this TSData series.
Optional<GCCloseable<FileChannel>>	getFileChannel() Return the file channel used to read this file, if it is uses a file descriptor.
long	getFileSize() Retrieve the filesize used by the TSData.
short	getMajor() Returns the major version of the TSData file.
short	getMinor() Returns the minor version of the TSData file.
com.groupon.lex.metrics.lib.sequence.ObjectSequence<TimeSeriesCollection>	getSequence()
boolean	isOptimized() Returns true if the file is optimized for access by (GroupPath, Tags, MetricName) tuple.
static UnmappedReadonlyTSDataFile	open(Path file)

Methods inherited from class com.groupon.lex.metrics.history.xdr.support.SequenceTSData

contains, containsAll, isEmpty, iterator, parallelStream, size, spliterator, stream, stream, stream, streamReversed, toArray, toArray

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

addAll, clear, 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

evaluate, evaluate, evaluate, getContext, getContext, getContext, stream, stream, stream

Constructor Detail

UnmappedReadonlyTSDataFile

public UnmappedReadonlyTSDataFile(GCCloseable<FileChannel> fd)
                           throws IOException

Throws:

IOException

Method Detail

open

public static UnmappedReadonlyTSDataFile open(Path file)
                                       throws IOException

Throws:

IOException

getSequence

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

Specified by:

getSequence in class SequenceTSData

getBegin

public org.joda.time.DateTime getBegin()

Description copied from interface: TSData

Get the lowest timestamp covered by this TSData series.

getEnd

public org.joda.time.DateTime getEnd()

Description copied from interface: TSData

Get the highest timestamp covered by this TSData series.

getMajor

public short getMajor()

Description copied from interface: TSData

Returns the major version of the TSData file. Note that this is the file-data version, not the application version.

getMinor

public short getMinor()

Description copied from interface: TSData

Returns the minor version of the TSData file. Note that this is the file-data version, not the application version.

getFileSize

public long getFileSize()

Description copied from interface: TSData

Retrieve the filesize used by the TSData.

canAddSingleRecord

public boolean canAddSingleRecord()

Description copied from interface: TSData

Returns true if the file is suitable for adding single records at a time.

isOptimized

public boolean isOptimized()

Description copied from interface: TSData

Returns true if the file is optimized for access by (GroupPath, Tags, MetricName) tuple.

add

public boolean add(TimeSeriesCollection tsv)

getFileChannel

public Optional<GCCloseable<FileChannel>> getFileChannel()

Description copied from interface: TSData

Return the file channel used to read this file, if it is uses a file descriptor. Returns Optional.empty() for memory mapped files.