com.groupon.lex.metrics.history.v2.list

Class RWListFile

java.lang.Object

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

com.groupon.lex.metrics.history.v2.list.RWListFile

All Implemented Interfaces:

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

public class RWListFile
extends SequenceTSData

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
RWListFile(GCCloseable<FileChannel> file, boolean forWrite)

Method Summary

Modifier and Type	Method and Description
boolean	add(TimeSeriesCollection tsc)
boolean	addAll(Collection<? extends TimeSeriesCollection> tsc)
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 RWListFile	newFile(GCCloseable<FileChannel> file)
static RWListFile	newFile(GCCloseable<FileChannel> file, Compression compression)

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

contains, containsAll, getAppendCompression, getOptimizedCompression, isEmpty, iterator, parallelStream, setAppendCompression, setOptimizedCompression, 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

asColumnMajorTSData, 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

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

Constructor Detail

RWListFile

public RWListFile(@NonNull
                  GCCloseable<FileChannel> file,
                  boolean forWrite)
           throws IOException,
                  org.acplt.oncrpc.OncRpcException

Throws:

IOException

org.acplt.oncrpc.OncRpcException

Method Detail

newFile

public static RWListFile newFile(@NonNull
                                 GCCloseable<FileChannel> file)
                          throws IOException

Throws:

IOException

newFile

public static RWListFile newFile(@NonNull
                                 GCCloseable<FileChannel> file,
                                 Compression compression)
                          throws IOException

Throws:

IOException

add

public boolean add(TimeSeriesCollection tsc)

addAll

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

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.

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.

getSequence

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

Specified by:

getSequence in class SequenceTSData

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.

getFileSize

public long getFileSize()

Description copied from interface: TSData

Retrieve the filesize used by the TSData.

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.