Class ByteInputKineticStream

  • All Implemented Interfaces:
    InputKineticStream, AutoCloseable

    public class ByteInputKineticStream
    extends Object
    implements InputKineticStream
    Kinetic stream implementation for deserialization of Java objects into sequence of bytes.
    • Constructor Detail

      • ByteInputKineticStream

        public ByteInputKineticStream​(DataInput in)
        Creates byte kinetic stream and attaches it to 'in'
    • Method Detail

      • readInt

        public int readInt()
                    throws IOException
        Specified by:
        readInt in interface InputKineticStream
        Throws:
        IOException
      • readFloat

        public float readFloat()
                        throws IOException
        Specified by:
        readFloat in interface InputKineticStream
        Throws:
        IOException
      • readBool

        public boolean readBool()
                         throws IOException
        Specified by:
        readBool in interface InputKineticStream
        Throws:
        IOException
      • readArray

        public Object[] readArray​(Class<?> type)
                           throws Exception
        Specified by:
        readArray in interface InputKineticStream
        Throws:
        Exception
      • close

        public void close()
                   throws Exception
        Specified by:
        close in interface AutoCloseable
        Throws:
        Exception