Uses of Interface
com.groupon.lex.metrics.history.xdr.support.reader.SegmentReader

Packages that use SegmentReader

Package	Description
com.groupon.lex.metrics.history.v2.list
com.groupon.lex.metrics.history.v2.tables
com.groupon.lex.metrics.history.xdr.support.reader

Uses of SegmentReader in com.groupon.lex.metrics.history.v2.list

Methods in com.groupon.lex.metrics.history.v2.list that return SegmentReader

Modifier and Type	Method and Description
static SegmentReader<DictionaryDelta>	ReadOnlyState.calculateDictionary(GCCloseable<FileChannel> file, Compression compression, List<SegmentReader<ReadonlyTSDataHeader>> tsdataList)
SegmentReader<Optional<dictionary_delta>>	ReadonlyTSDataHeader.dictionaryDecoder(GCCloseable<FileChannel> file, Compression compression)
static SegmentReader<ReadonlyTSDataHeader>	ReadOnlyState.readTSDataHeader(GCCloseable<FileChannel> file, FilePos pos)
SegmentReader<record_array>	ReadonlyTSDataHeader.recordsDecoder(GCCloseable<FileChannel> file, Compression compression)

Methods in com.groupon.lex.metrics.history.v2.list that return types with arguments of type SegmentReader

Modifier and Type	Method and Description
static List<SegmentReader<TimeSeriesCollection>>	ReadOnlyState.calculateTimeSeries(GCCloseable<FileChannel> file, Compression compression, List<SegmentReader<ReadonlyTSDataHeader>> tsdataList, SegmentReader<DictionaryDelta> dictionary)
static List<SegmentReader<ReadonlyTSDataHeader>>	ReadOnlyState.readAllTSDataHeaders(GCCloseable<FileChannel> file, FilePos recordPos)
com.groupon.lex.metrics.lib.sequence.ObjectSequence<SegmentReader<TimeSeriesCollection>>	State.sequence()
com.groupon.lex.metrics.lib.sequence.ObjectSequence<SegmentReader<TimeSeriesCollection>>	ReadWriteState.sequence()
com.groupon.lex.metrics.lib.sequence.ObjectSequence<SegmentReader<TimeSeriesCollection>>	ReadOnlyState.sequence()

Methods in com.groupon.lex.metrics.history.v2.list with parameters of type SegmentReader

Modifier and Type	Method and Description
static List<SegmentReader<TimeSeriesCollection>>	ReadOnlyState.calculateTimeSeries(GCCloseable<FileChannel> file, Compression compression, List<SegmentReader<ReadonlyTSDataHeader>> tsdataList, SegmentReader<DictionaryDelta> dictionary)

Method parameters in com.groupon.lex.metrics.history.v2.list with type arguments of type SegmentReader

Modifier and Type	Method and Description
static SegmentReader<DictionaryDelta>	ReadOnlyState.calculateDictionary(GCCloseable<FileChannel> file, Compression compression, List<SegmentReader<ReadonlyTSDataHeader>> tsdataList)
static List<SegmentReader<TimeSeriesCollection>>	ReadOnlyState.calculateTimeSeries(GCCloseable<FileChannel> file, Compression compression, List<SegmentReader<ReadonlyTSDataHeader>> tsdataList, SegmentReader<DictionaryDelta> dictionary)

Constructors in com.groupon.lex.metrics.history.v2.list with parameters of type SegmentReader

Constructor and Description
ListTSC(org.joda.time.DateTime ts, SegmentReader<record_array> init, SegmentReader<DictionaryDelta> dictSegment, FileChannelSegmentReader.Factory segmentFactory)
ListTSC(org.joda.time.DateTime ts, SegmentReader<record_array> init, SegmentReader<DictionaryDelta> dictSegment, FileChannelSegmentReader.Factory segmentFactory)

Uses of SegmentReader in com.groupon.lex.metrics.history.v2.tables

Methods in com.groupon.lex.metrics.history.v2.tables that return SegmentReader

Modifier and Type	Method and Description
SegmentReader<RTFMetricTable>	RTFGroupTable.getMetric(MetricName name)

Uses of SegmentReader in com.groupon.lex.metrics.history.xdr.support.reader

Classes in com.groupon.lex.metrics.history.xdr.support.reader that implement SegmentReader

Modifier and Type	Class and Description
class	FileChannelSegmentReader<T extends org.acplt.oncrpc.XdrAble>

Methods in com.groupon.lex.metrics.history.xdr.support.reader that return SegmentReader

Modifier and Type	Method and Description
default SegmentReader<T>	SegmentReader.cache()
default SegmentReader<T>	SegmentReader.cache(T current)
default <U,R> SegmentReader<R>	SegmentReader.combine(SegmentReader<U> other, BiFunction<? super T,? super U,? extends R> fn)
default SegmentReader<Optional<T>>	SegmentReader.filter(Predicate<? super T> pred)
default <U> SegmentReader<U>	SegmentReader.flatMap(Function<? super T,? extends SegmentReader<? extends U>> fn)
<T extends BaseType> SegmentReader<T>	SegmentReader.Factory.get(Supplier<T> type, FilePos pos)
<T extends org.acplt.oncrpc.XdrAble> SegmentReader<T>	FileChannelSegmentReader.Factory.get(Supplier<T> type, FilePos pos)
default <U> SegmentReader<U>	SegmentReader.map(Function<? super T,? extends U> fn)
static <T> SegmentReader<T>	SegmentReader.of(T v)
static <T> SegmentReader<T>	SegmentReader.ofSupplier(Supplier<T> v)
default SegmentReader<T>	SegmentReader.peek(Consumer<? super T> fn)
default SegmentReader<T>	SegmentReader.share()

Methods in com.groupon.lex.metrics.history.xdr.support.reader with parameters of type SegmentReader

Modifier and Type	Method and Description
default <U,R> SegmentReader<R>	SegmentReader.combine(SegmentReader<U> other, BiFunction<? super T,? super U,? extends R> fn)

Method parameters in com.groupon.lex.metrics.history.xdr.support.reader with type arguments of type SegmentReader

Modifier and Type	Method and Description
default <U> SegmentReader<U>	SegmentReader.flatMap(Function<? super T,? extends SegmentReader<? extends U>> fn)