Interface DataSink

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void append​(String key, Object value)
      Appends the specified data to this sink.
      void close()
      Close this DataSink.
      void flush()
      Flushes any data buffered by this DataSink.
      void open​(List<String> sourceIds)
      Open this DataSink.
      void recordEnded()
      Notified this DataSink that the current record has ended.
      void rowEnded()
      Notifies this DataSink that the last append was end of a "row."
      void rowStarted()
      Notifies this DataSink that the next append is that start of a "row." of data.
    • Method Detail

      • open

        void open​(List<String> sourceIds)
        Open this DataSink.
        Parameters:
        sourceIds - a list of the DataSource ids for which this is the sink.
        Throws:
        DataException - if there is an error opening the sink.
      • rowStarted

        void rowStarted()
        Notifies this DataSink that the next append is that start of a "row." of data.
      • append

        void append​(String key,
                    Object value)
        Appends the specified data to this sink. The key can be, for example, a column name and the value the current value for that column.
        Parameters:
        key - the data's key
        value - the data's value
      • rowEnded

        void rowEnded()
        Notifies this DataSink that the last append was end of a "row."
      • recordEnded

        void recordEnded()
        Notified this DataSink that the current record has ended.
      • flush

        void flush()
        Flushes any data buffered by this DataSink.
      • close

        void close()
        Close this DataSink.