Class CsvInputKineticStream

  • All Implemented Interfaces:
    InputKineticStream, AutoCloseable

    public class CsvInputKineticStream
    extends Object
    implements InputKineticStream
    Kinetic stream implementation for deserialization of Java objects from stream of CSV lines.
    • Constructor Detail

      • CsvInputKineticStream

        public CsvInputKineticStream​(BufferedReader lines)
        Create CSV kinetic input stream
        Parameters:
        lines - lines reader from CSV file
    • 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