Package org.apache.druid.frame.processor

Class ComposingOutputChannelFactory

java.lang.Object

org.apache.druid.frame.processor.ComposingOutputChannelFactory

All Implemented Interfaces:

OutputChannelFactory

public class ComposingOutputChannelFactory
extends Object
implements OutputChannelFactory

A channel factory which provides ordered composed channels. The factory encapsulates multiple output channel factories and automatically switches between then when the current factory is 'full' for writes. The reads can also encapsulate multiple readable channels with automatic switching.

Constructor Summary

Constructors

Constructor	Description
ComposingOutputChannelFactory(List<OutputChannelFactory> channelFactories, int frameSize)

Method Summary

Modifier and Type	Method	Description
boolean	isBuffered()	Whether this factory creates buffered channels.
OutputChannel	openChannel(int partitionNumber)	Create a channel pair tagged with a particular partition number.
OutputChannel	openNilChannel(int partitionNumber)	Create a non-writable, always-empty channel pair tagged with a particular partition number.
PartitionedOutputChannel	openPartitionedChannel(String name, boolean deleteAfterRead)	Create a channel pair tagged with a particular name and a flag to delete the channel data after its read.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ComposingOutputChannelFactory

public ComposingOutputChannelFactory(List<OutputChannelFactory> channelFactories,
 int frameSize)

Method Details

openChannel

public OutputChannel openChannel(int partitionNumber)

Description copied from interface: OutputChannelFactory

Create a channel pair tagged with a particular partition number.

Specified by:

openChannel in interface OutputChannelFactory

openPartitionedChannel

public PartitionedOutputChannel openPartitionedChannel(String name,
 boolean deleteAfterRead)

Description copied from interface: OutputChannelFactory

Create a channel pair tagged with a particular name and a flag to delete the channel data after its read.

Specified by:

openPartitionedChannel in interface OutputChannelFactory

openNilChannel

public OutputChannel openNilChannel(int partitionNumber)

Description copied from interface: OutputChannelFactory

Create a non-writable, always-empty channel pair tagged with a particular partition number. Calling OutputChannel.getWritableChannel() on this nil channel pair will result in an error. Calling OutputChannel.getReadableChannel() will return an empty channel.

Specified by:

openNilChannel in interface OutputChannelFactory

isBuffered

public boolean isBuffered()

Description copied from interface: OutputChannelFactory

Whether this factory creates buffered channels. Buffered channel readers (from OutputChannel.getReadableChannel()) will not work properly until the writer is closed. Unbuffered readers work immediately, even while the writer is open.

Specified by:

isBuffered in interface OutputChannelFactory

toString

public String toString()

Overrides:

toString in class Object