Package com.illumon.iris.db.v2.locations.local

Class TrackedSeekableChannelsProvider

java.lang.Object

com.illumon.iris.db.v2.locations.local.TrackedSeekableChannelsProvider

All Implemented Interfaces:

io.deephaven.parquet.base.util.SeekableChannelsProvider

public class TrackedSeekableChannelsProvider
extends Object
implements io.deephaven.parquet.base.util.SeekableChannelsProvider

SeekableChannelsProvider implementation that is constrained a Deephaven TrackedFileHandleFactory.

Constructor Summary

Constructors

Constructor	Description
TrackedSeekableChannelsProvider(TrackedFileHandleFactory fileHandleFactory)

Method Summary

Modifier and Type	Method	Description
static io.deephaven.parquet.base.util.SeekableChannelsProvider	getInstance()
SeekableByteChannel	getReadChannel(Path path)
SeekableByteChannel	getWriteChannel(Path filePath, boolean append)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.parquet.base.util.SeekableChannelsProvider

getReadChannel, getWriteChannel

Constructor Details

TrackedSeekableChannelsProvider

public TrackedSeekableChannelsProvider(@NotNull TrackedFileHandleFactory fileHandleFactory)

Method Details

getInstance

public static io.deephaven.parquet.base.util.SeekableChannelsProvider getInstance()

getReadChannel

public final SeekableByteChannel getReadChannel(@NotNull Path path) throws IOException

Specified by:

getReadChannel in interface io.deephaven.parquet.base.util.SeekableChannelsProvider

Throws:

IOException

getWriteChannel

public final SeekableByteChannel getWriteChannel(@NotNull Path filePath, boolean append) throws IOException

Specified by:

getWriteChannel in interface io.deephaven.parquet.base.util.SeekableChannelsProvider

Throws:

IOException