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

Class ReadOnlyState

java.lang.Object

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

All Implemented Interfaces:

State

public class ReadOnlyState
extends Object
implements State

Constructor Summary

Constructors

Constructor and Description
ReadOnlyState(GCCloseable<FileChannel> file, tsfile_header hdr)

Method Summary

Modifier and Type	Method and Description
void	add(TimeSeriesCollection tsc)
void	addAll(Collection<? extends TimeSeriesCollection> tsc)
static SegmentReader<DictionaryDelta>	calculateDictionary(GCCloseable<FileChannel> file, Compression compression, List<SegmentReader<ReadonlyTSDataHeader>> tsdataListArg)
static List<SegmentReader<TimeSeriesCollection>>	calculateTimeSeries(GCCloseable<FileChannel> file, Compression compression, List<SegmentReader<ReadonlyTSDataHeader>> tsdataList, SegmentReader<DictionaryDelta> dictionary)
static List<SegmentReader<ReadonlyTSDataHeader>>	readAllTSDataHeaders(GCCloseable<FileChannel> file, FilePos recordPos)
static SegmentReader<ReadonlyTSDataHeader>	readTSDataHeader(GCCloseable<FileChannel> file, FilePos pos)
com.groupon.lex.metrics.lib.sequence.ObjectSequence<SegmentReader<TimeSeriesCollection>>	sequence()

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.v2.list.State

decodedSequence, getBegin, getEnd, getFile

Constructor Detail

ReadOnlyState

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

Throws:

IOException

org.acplt.oncrpc.OncRpcException

Method Detail

sequence

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

Specified by:

sequence in interface State

add

public void add(TimeSeriesCollection tsc)

Specified by:

add in interface State

addAll

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

Specified by:

addAll in interface State

readAllTSDataHeaders

public static List<SegmentReader<ReadonlyTSDataHeader>> readAllTSDataHeaders(GCCloseable<FileChannel> file,
                                                                             FilePos recordPos)
                                                                      throws IOException,
                                                                             org.acplt.oncrpc.OncRpcException

Throws:

IOException

org.acplt.oncrpc.OncRpcException

readTSDataHeader

public static SegmentReader<ReadonlyTSDataHeader> readTSDataHeader(GCCloseable<FileChannel> file,
                                                                   FilePos pos)

calculateDictionary

public static SegmentReader<DictionaryDelta> calculateDictionary(GCCloseable<FileChannel> file,
                                                                 Compression compression,
                                                                 List<SegmentReader<ReadonlyTSDataHeader>> tsdataListArg)

calculateTimeSeries

public static List<SegmentReader<TimeSeriesCollection>> calculateTimeSeries(GCCloseable<FileChannel> file,
                                                                            Compression compression,
                                                                            List<SegmentReader<ReadonlyTSDataHeader>> tsdataList,
                                                                            SegmentReader<DictionaryDelta> dictionary)