Class AbstractDataSet

    • Constructor Detail

      • AbstractDataSet

        public AbstractDataSet​(String id)
    • Method Detail

      • getId

        public String getId()
        Description copied from interface: DataSet
        Gets the id of this DataSet.
        Specified by:
        getId in interface DataSet
        Returns:
        the id of this DataSet.
      • sinks

        public Iterable<DataSink> sinks()
        Description copied from interface: DataSet
        Gets the sinks associated with this DataSet.
        Specified by:
        sinks in interface DataSet
        Returns:
        the sinks associated with this DataSet.
      • init

        public void init()
        Description copied from interface: DataSet
        Initializes this DataSet.
        Specified by:
        init in interface DataSet
      • getSourceIds

        protected abstract List<String> getSourceIds()
      • flush

        public void flush()
        Description copied from interface: DataSet
        Notifies the sinks associated with this DataSet to flush their buffered data (if any).
        Specified by:
        flush in interface DataSet
      • close

        public void close()
        Description copied from interface: DataSet
        Closes this DataSet.
        Specified by:
        close in interface DataSet