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

Class ReadWriteState

java.lang.Object

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

All Implemented Interfaces:

State

public final class ReadWriteState
extends Object
implements State

Author:

ariane

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	add(TimeSeriesCollection tsc)
void	addAll(Collection<? extends TimeSeriesCollection> tsc)
org.joda.time.DateTime	getBegin()
org.joda.time.DateTime	getEnd()
boolean	isDistinct()
boolean	isSorted()
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, getFile

Constructor Detail

ReadWriteState

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

Throws:

IOException

org.acplt.oncrpc.OncRpcException

Method Detail

isSorted

public boolean isSorted()

isDistinct

public boolean isDistinct()

getBegin

public org.joda.time.DateTime getBegin()

Specified by:

getBegin in interface State

getEnd

public org.joda.time.DateTime getEnd()

Specified by:

getEnd in interface State

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