Package org.apache.beam.sdk.util

Class LzoCompression

  • public class LzoCompression
extends java.lang.Object

    • Constructor Summary

      Constructors 
      Constructor Description
      LzoCompression()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static java.io.InputStream createLzoInputStream​(java.io.InputStream inputStream)
      Create an InputStream that will read from the given InputStream using LzoCodec.
      static java.io.OutputStream createLzoOutputStream​(java.io.OutputStream outputStream)
      Create an OutputStream that will write to the given OutputStream.
      static java.io.InputStream createLzopInputStream​(java.io.InputStream inputStream)
      Create an InputStream that will read from the given InputStream using LzopCodec.
      static java.io.OutputStream createLzopOutputStream​(java.io.OutputStream outputStream)
      Create a OutputStream that will write to the given OutputStream.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • LzoCompression

        public LzoCompression()

    • Method Detail

      • createLzoInputStream

        public static java.io.InputStream createLzoInputStream​(java.io.InputStream inputStream)
                                                throws java.io.IOException
        Create an InputStream that will read from the given InputStream using LzoCodec.
        Parameters:
        inputStream - the stream to read compressed bytes from
        Returns:
        a stream to read uncompressed bytes from
        Throws:
        java.io.IOException

      • createLzopInputStream

        public static java.io.InputStream createLzopInputStream​(java.io.InputStream inputStream)
                                                 throws java.io.IOException
        Create an InputStream that will read from the given InputStream using LzopCodec.
        Parameters:
        inputStream - the stream to read compressed bytes from
        Returns:
        a stream to read uncompressed bytes from
        Throws:
        java.io.IOException

      • createLzoOutputStream

        public static java.io.OutputStream createLzoOutputStream​(java.io.OutputStream outputStream)
                                                  throws java.io.IOException
        Create an OutputStream that will write to the given OutputStream.
        Parameters:
        outputStream - the location for the final output stream
        Returns:
        a stream the user can write uncompressed data to have it compressed
        Throws:
        java.io.IOException

      • createLzopOutputStream

        public static java.io.OutputStream createLzopOutputStream​(java.io.OutputStream outputStream)
                                                   throws java.io.IOException
        Create a OutputStream that will write to the given OutputStream.
        Parameters:
        outputStream - the location for the final output stream
        Returns:
        a stream the user can write uncompressed data to have it compressed
        Throws:
        java.io.IOException