org.apache.beam.sdk.io

Interface CompressedSource.DecompressingChannelFactory

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

CompressedSource.CompressionMode

Enclosing class:

CompressedSource<T>

public static interface CompressedSource.DecompressingChannelFactory
extends java.io.Serializable

Factory interface for creating channels that decompress the content of an underlying channel.

Method Summary

Modifier and Type	Method and Description
java.nio.channels.ReadableByteChannel	createDecompressingChannel(java.nio.channels.ReadableByteChannel channel) Given a channel, create a channel that decompresses the content read from the channel.

Method Detail

createDecompressingChannel

java.nio.channels.ReadableByteChannel createDecompressingChannel(java.nio.channels.ReadableByteChannel channel)
                                                          throws java.io.IOException

Given a channel, create a channel that decompresses the content read from the channel.

Throws:

java.io.IOException