Package io.deephaven.util.channel

Class LocalFSChannelProvider

java.lang.Object

io.deephaven.util.channel.LocalFSChannelProvider

All Implemented Interfaces:

SeekableChannelsProvider, SafeCloseable, AutoCloseable

public class LocalFSChannelProvider
extends Object
implements SeekableChannelsProvider

Constructor Summary

Constructors

Constructor	Description
LocalFSChannelProvider()

Method Summary

Modifier and Type	Method	Description
void	close()
InputStream	getInputStream(SeekableByteChannel channel)	Creates an InputStream from the current position of channel; closing the resulting input stream does not close the channel.
SeekableByteChannel	getReadChannel(@Nullable SeekableChannelContext channelContext, @NotNull URI uri)
SeekableByteChannel	getWriteChannel(@NotNull Path filePath, boolean append)
boolean	isCompatibleWith(@Nullable SeekableChannelContext channelContext)	Check if the given context is compatible with this provider.
final Stream<URI>	list(@NotNull URI directory)	Returns a stream of URIs, the elements of which are the entries in the directory.
SeekableChannelContext	makeContext()	Create a new SeekableChannelContext object for creating read channels via this provider.
final Stream<URI>	walk(@NotNull URI directory)	Returns a stream of URIs, the elements of which are all the files in the file tree rooted at the given starting directory.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.util.channel.SeekableChannelsProvider

getReadChannel, getWriteChannel, makeSingleUseContext

Constructor Details

LocalFSChannelProvider

public LocalFSChannelProvider()

Method Details

makeContext

public SeekableChannelContext makeContext()

Description copied from interface: SeekableChannelsProvider

Create a new SeekableChannelContext object for creating read channels via this provider.

Specified by:

makeContext in interface SeekableChannelsProvider

isCompatibleWith

public boolean isCompatibleWith(@Nullable
 @Nullable SeekableChannelContext channelContext)

Description copied from interface: SeekableChannelsProvider

Check if the given context is compatible with this provider. Useful to test if we can use provided context object for creating channels with this provider.

Specified by:

isCompatibleWith in interface SeekableChannelsProvider

getReadChannel

public SeekableByteChannel getReadChannel(@Nullable
 @Nullable SeekableChannelContext channelContext,
 @NotNull
 @NotNull URI uri)
                                   throws IOException

Specified by:

getReadChannel in interface SeekableChannelsProvider

Throws:

IOException

getInputStream

public InputStream getInputStream(SeekableByteChannel channel)

Description copied from interface: SeekableChannelsProvider

Creates an InputStream from the current position of channel; closing the resulting input stream does not close the channel. The InputStream will be buffered; either explicitly in the case where the implementation uses an unbuffered SeekableChannelsProvider.getReadChannel(SeekableChannelContext, URI), or implicitly when the implementation uses a buffered SeekableChannelsProvider.getReadChannel(SeekableChannelContext, URI). channel must have been created by this provider. The caller can't assume the position of channel after consuming the InputStream. For use-cases that require the channel's position to be incremented the exact amount the InputStream has been consumed, use SeekableChannelsProvider.channelPositionInputStream(SeekableChannelsProvider, SeekableByteChannel).

Specified by:

getInputStream in interface SeekableChannelsProvider

Parameters:

channel - the channel

Returns:

the input stream

getWriteChannel

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

Specified by:

getWriteChannel in interface SeekableChannelsProvider

Throws:

IOException

list

public final Stream<URI> list(@NotNull
 @NotNull URI directory)
                       throws IOException

Description copied from interface: SeekableChannelsProvider

Returns a stream of URIs, the elements of which are the entries in the directory. The listing is non-recursive. The URIs supplied by the stream will not have any unnecessary slashes or path separators. Also, the URIs will be file URIs (not ending with "/") irrespective of whether the URI corresponds to a file or a directory. The caller should manage file vs. directory handling in the processor. The caller is also responsible for closing the stream, preferably using a try-with-resources block.

Specified by:

list in interface SeekableChannelsProvider

Parameters:

directory - the URI of the directory to list

Returns:

The Stream of URIs

Throws:

IOException

walk

public final Stream<URI> walk(@NotNull
 @NotNull URI directory)
                       throws IOException

Description copied from interface: SeekableChannelsProvider

Returns a stream of URIs, the elements of which are all the files in the file tree rooted at the given starting directory. The URIs supplied by the stream will not have any unnecessary slashes or path separators. Also, the URIs will be file URIs (not ending with "/") irrespective of whether the URI corresponds to a file or a directory. The caller should manage file vs. directory handling in the processor. The caller is also responsible for closing the stream, preferably using a try-with-resources block.

Specified by:

walk in interface SeekableChannelsProvider

Parameters:

directory - the URI of the directory to walk

Returns:

The Stream of URIs

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface SafeCloseable