Package 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

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method 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