Package io.deephaven.parquet.base.util

Class CachedChannelProvider

java.lang.Object

io.deephaven.parquet.base.util.CachedChannelProvider

All Implemented Interfaces:

SeekableChannelsProvider

public class CachedChannelProvider
extends Object
implements SeekableChannelsProvider

Channel provider that will cache a bounded number of unused channels.

Constructor Summary

Constructors

Constructor	Description
CachedChannelProvider(@NotNull SeekableChannelsProvider wrappedProvider, int maximumPooledCount)

Method Summary

Modifier and Type	Method	Description
SeekableByteChannel	getReadChannel(@NotNull Path path)
SeekableByteChannel	getWriteChannel(@NotNull Path path, 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

CachedChannelProvider

public CachedChannelProvider(@NotNull
 @NotNull SeekableChannelsProvider wrappedProvider,
 int maximumPooledCount)

Method Details

getReadChannel

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

Specified by:

getReadChannel in interface SeekableChannelsProvider

Throws:

IOException

getWriteChannel

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

Specified by:

getWriteChannel in interface SeekableChannelsProvider

Throws:

IOException