Package org.apache.druid.frame.channel

Class FrameChannelSequence

java.lang.Object

org.apache.druid.java.util.common.guava.BaseSequence<RowsAndColumns,FrameChannelSequence.FrameChannelIterator>

org.apache.druid.frame.channel.FrameChannelSequence

All Implemented Interfaces:

Sequence<RowsAndColumns>

public class FrameChannelSequence
extends BaseSequence<RowsAndColumns,FrameChannelSequence.FrameChannelIterator>

Adapter that converts a ReadableFrameChannel into a Sequence of RowsAndColumns. This class does blocking reads on the channel. Therefore, it is preferable to use ReadableFrameChannel directly whenever nonblocking reads are desired.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FrameChannelSequence.FrameChannelIterator

Nested classes/interfaces inherited from class org.apache.druid.java.util.common.guava.BaseSequence

BaseSequence.IteratorMaker<T,IterType extends Iterator<T>>

Constructor Summary

Constructors

Constructor	Description
FrameChannelSequence(ReadableFrameChannel channel)

Method Summary

Methods inherited from class org.apache.druid.java.util.common.guava.BaseSequence

accumulate, toYielder

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.druid.java.util.common.guava.Sequence

filter, flatMap, flatMerge, forEach, limit, map, skip, toList, withBaggage, withEffect

Constructor Details

FrameChannelSequence

public FrameChannelSequence(ReadableFrameChannel channel)