Module id.kineticstreamer
Package id.kineticstreamer

Interface InputKineticStream

  • All Superinterfaces:
    AutoCloseable
    All Known Implementing Classes:
    ByteInputKineticStream, CsvInputKineticStream
    public interface InputKineticStream
extends AutoCloseable

    Interface which needs to be implemented to support deserialization of new types of kinetic streams.

    All of them read values from the stream which were previously written there by OutputKineticStream.

    • Method Detail

      • readString

        String readString()
           throws Exception
        Throws:
        Exception

      • readInt

        int readInt()
     throws Exception
        Throws:
        Exception

      • readFloat

        float readFloat()
         throws Exception
        Throws:
        Exception

      • readDouble

        double readDouble()
           throws Exception
        Throws:
        Exception

      • readBool

        boolean readBool()
          throws Exception
        Throws:
        Exception

      • readByte

        byte readByte()
       throws Exception
        Throws:
        Exception

      • readArray

        Object[] readArray​(Class<?> type)
            throws Exception
        Throws:
        Exception

      • readIntArray

        int[] readIntArray()
            throws Exception
        Throws:
        Exception

      • readByteArray

        byte[] readByteArray()
              throws Exception
        Throws:
        Exception

      • readDoubleArray

        double[] readDoubleArray()
                  throws Exception
        Throws:
        Exception

      • readBooleanArray

        boolean[] readBooleanArray()
                    throws Exception
        Throws:
        Exception