Package org.apache.druid.frame.channel

Class DurableStoragePartitionedReadableFrameChannel

java.lang.Object

org.apache.druid.frame.channel.DurableStoragePartitionedReadableFrameChannel

All Implemented Interfaces:

Closeable, AutoCloseable, PartitionedReadableFrameChannel

public class DurableStoragePartitionedReadableFrameChannel
extends Object
implements PartitionedReadableFrameChannel

Constructor Summary

Constructors

Constructor	Description
DurableStoragePartitionedReadableFrameChannel(StorageConnector storageConnector, Supplier<FrameFileFooter> frameFileFooterSupplier, String frameFileFullPath, ExecutorService remoteInputStreamPool, File footerFile, WireTransferableContext wireTransferableContext)

Method Summary

Modifier and Type	Method	Description
void	close()	Releases any resources associated with this readable channel.
ReadableFrameChannel	getReadableFrameChannel(int partitionNumber)	Allows reading a particular partition in the channel

Methods inherited from class java.lang.Object

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

Constructor Details

DurableStoragePartitionedReadableFrameChannel

public DurableStoragePartitionedReadableFrameChannel(StorageConnector storageConnector,
 Supplier<FrameFileFooter> frameFileFooterSupplier,
 String frameFileFullPath,
 ExecutorService remoteInputStreamPool,
 File footerFile,
 @Nullable
 WireTransferableContext wireTransferableContext)

Method Details

getReadableFrameChannel

public ReadableFrameChannel getReadableFrameChannel(int partitionNumber)

Description copied from interface: PartitionedReadableFrameChannel

Allows reading a particular partition in the channel

Specified by:

getReadableFrameChannel in interface PartitionedReadableFrameChannel

Parameters:

partitionNumber - the partition to read

Returns:

a ReadableFrameChannel for the partition queried

close

public void close()

Description copied from interface: PartitionedReadableFrameChannel

Releases any resources associated with this readable channel. After calling this, you should not call any other methods on the channel.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface PartitionedReadableFrameChannel