Package io.deephaven.parquet.table.util

Class TrackedSeekableChannelsProvider

java.lang.Object

io.deephaven.parquet.table.util.TrackedSeekableChannelsProvider

All Implemented Interfaces:

SeekableChannelsProvider

public class TrackedSeekableChannelsProvider
extends Object
implements SeekableChannelsProvider

SeekableChannelsProvider implementation that is constrained by a Deephaven TrackedFileHandleFactory.

Constructor Summary

Constructors

Constructor	Description
TrackedSeekableChannelsProvider(@NotNull TrackedFileHandleFactory fileHandleFactory)

Method Summary

Modifier and Type	Method	Description
static SeekableChannelsProvider	getInstance()
final SeekableByteChannel	getReadChannel(@NotNull Path path)
final SeekableByteChannel	getWriteChannel(@NotNull 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
 @NotNull TrackedFileHandleFactory fileHandleFactory)

Method Details

getInstance

public static SeekableChannelsProvider getInstance()

getReadChannel

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

Specified by:

getReadChannel in interface SeekableChannelsProvider

Throws:

IOException

getWriteChannel

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

Specified by:

getWriteChannel in interface SeekableChannelsProvider

Throws:

IOException