Class FileDataSink

  • All Implemented Interfaces:
    DataSink

    public class FileDataSink
    extends Object
    implements DataSink
    DataSink that writes data to a file in tabular format.
    Author:
    Nick Collier
    • Constructor Detail

    • Method Detail

      • getFile

        public File getFile()
        Gets the file this FileDataSink will write to.
        Returns:
        the file this FileDataSink will write to.
      • getName

        public String getName()
        Gets the name of this FileDataSink.
        Returns:
        the name of this FileDataSink.
      • getFormatter

        public Formatter getFormatter()
        Gets the formatter used to format the data written using this FileDataSink.
        Returns:
        the formatter used to format the data written using this FileDataSink.
      • getFormat

        public FormatType getFormat()
        Gets the format type for this FileDataSink.
        Returns:
        the format type for this FileDataSink.
      • open

        public void open​(List<String> sourceIds)
        Description copied from interface: DataSink
        Open this DataSink.
        Specified by:
        open in interface DataSink
        Parameters:
        sourceIds - a list of the DataSource ids for which this is the sink.
      • flush

        public void flush()
        Description copied from interface: DataSink
        Flushes any data buffered by this DataSink.
        Specified by:
        flush in interface DataSink
      • rowStarted

        public void rowStarted()
        Description copied from interface: DataSink
        Notifies this DataSink that the next append is that start of a "row." of data.
        Specified by:
        rowStarted in interface DataSink
      • append

        public void append​(String key,
                           Object value)
        Description copied from interface: DataSink
        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.
        Specified by:
        append in interface DataSink
        Parameters:
        key - the data's key
        value - the data's value
      • rowEnded

        public void rowEnded()
        Description copied from interface: DataSink
        Notifies this DataSink that the last append was end of a "row."
        Specified by:
        rowEnded in interface DataSink
      • recordEnded

        public void recordEnded()
        Description copied from interface: DataSink
        Notified this DataSink that the current record has ended.
        Specified by:
        recordEnded in interface DataSink
      • close

        public void close()
        Description copied from interface: DataSink
        Close this DataSink.
        Specified by:
        close in interface DataSink