com.groupon.lex.metrics.history.v2.tables

Class ReadonlyTableFile

java.lang.Object

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

com.groupon.lex.metrics.history.v2.tables.ReadonlyTableFile

All Implemented Interfaces:

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

public class ReadonlyTableFile
extends SequenceTSData
implements ColumnMajorTSData

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
ReadonlyTableFile(GCCloseable<FileChannel> file)

Method Summary

Modifier and Type	Method and Description
boolean	add(TimeSeriesCollection tsv)
ColumnMajorTSData	asColumnMajorTSData() Returns the data in column major format.
boolean	canAddSingleRecord() Returns true if the file is suitable for adding single records at a time.
Optional<GCCloseable<FileChannel>>	getFileChannel() Return the file channel used to read this file, if it is uses a file descriptor.
Set<GroupName>	getGroupNames() Retrieve all group names covered in this.
Collection<org.joda.time.DateTime>	getGroupTimestamps(GroupName group) Retrieve all timestamps at which this group exists.
short	getMajor() Returns the major version of the TSData file.
Set<MetricName>	getMetricNames(GroupName group) Retrieve all metric names in the specific group.
Map<org.joda.time.DateTime,MetricValue>	getMetricValues(GroupName group, MetricName metric) Retrieve all metric values, mapped by timestamp.
short	getMinor() Returns the minor version of the TSData file.
com.groupon.lex.metrics.lib.sequence.ObjectSequence<TimeSeriesCollection>	getSequence()
Collection<org.joda.time.DateTime>	getTimestamps() Retrieve all timestamps covered in this.
boolean	isOptimized() Returns true if the file is optimized for access by (GroupPath, Tags, MetricName) tuple.

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

addAll, clear, getBegin, getEnd, getFileSize, 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

ReadonlyTableFile

public ReadonlyTableFile(GCCloseable<FileChannel> file)
                  throws IOException,
                         org.acplt.oncrpc.OncRpcException

Throws:

IOException

org.acplt.oncrpc.OncRpcException

Method Detail

add

public boolean add(TimeSeriesCollection tsv)

Specified by:

add in interface CollectHistory

Specified by:

add in interface TSData

Specified by:

add in interface Collection<TimeSeriesCollection>

getSequence

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

Specified by:

getSequence in class SequenceTSData

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.

Specified by:

getMajor in interface TSData

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.

Specified by:

getMinor in interface TSData

canAddSingleRecord

public boolean canAddSingleRecord()

Description copied from interface: TSData

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

Specified by:

canAddSingleRecord in interface TSData

isOptimized

public boolean isOptimized()

Description copied from interface: TSData

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

Specified by:

isOptimized in interface TSData

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.

Specified by:

getFileChannel in interface TSData

getTimestamps

public Collection<org.joda.time.DateTime> getTimestamps()

Description copied from interface: ColumnMajorTSData

Retrieve all timestamps covered in this.

Specified by:

getTimestamps in interface ColumnMajorTSData

Returns:

The timestamps covered in this. Timestamps may be unordered.

getGroupNames

public Set<GroupName> getGroupNames()

Description copied from interface: ColumnMajorTSData

Retrieve all group names covered in this.

Specified by:

getGroupNames in interface ColumnMajorTSData

Returns:

The group names present in this TSData.

getGroupTimestamps

public Collection<org.joda.time.DateTime> getGroupTimestamps(GroupName group)

Description copied from interface: ColumnMajorTSData

Retrieve all timestamps at which this group exists.

Specified by:

getGroupTimestamps in interface ColumnMajorTSData

Returns:

The timestamps at which the group exists. Timestamps may be unordered.

getMetricNames

public Set<MetricName> getMetricNames(GroupName group)

Description copied from interface: ColumnMajorTSData

Retrieve all metric names in the specific group.

Specified by:

getMetricNames in interface ColumnMajorTSData

Parameters:

group - The group for which to look up metric names.

Returns:

All metric names for the given group (irrespective of at which timestamp).

getMetricValues

public Map<org.joda.time.DateTime,MetricValue> getMetricValues(GroupName group,
                                                               MetricName metric)

Description copied from interface: ColumnMajorTSData

Retrieve all metric values, mapped by timestamp.

Specified by:

getMetricValues in interface ColumnMajorTSData

Parameters:

group - The group in which to look for values.

metric - The metric in the group, for which to retrieve metric values.

Returns:

A map of timestamped metric values.

asColumnMajorTSData

public ColumnMajorTSData asColumnMajorTSData()

Description copied from interface: TSData

Returns the data in column major format. The TSData instance may perform expensive computation to make this work.

Specified by:

asColumnMajorTSData in interface TSData

Returns:

The data in column major format.