Class AbstractDataSetBuilder

    • Constructor Detail

      • AbstractDataSetBuilder

        public AbstractDataSetBuilder​(String id)
    • Method Detail

      • defineScheduleParameters

        public void defineScheduleParameters​(ScheduleParameters params,
                                             boolean atEnd)
      • isScheduleAtEnd

        public boolean isScheduleAtEnd()
      • getId

        public String getId()
      • addFileDataSinkBuilder

        public void addFileDataSinkBuilder​(FileDataSinkBuilder builder)
        Defines a FileDataSink for this DataSet. The data retrieved from the defined data sources will be written to the defined DataSink.
        Parameters:
        fileName -
        delimiter -
        formatType -
        addTimeStamp -
        sourceIds -
      • defineConsoleDataSink

        public void defineConsoleDataSink​(ConsoleDataSink.OutputStream target,
                                          String delimiter,
                                          FormatType formatType,
                                          Collection<String> sourceIds)
        Defines a ConsoleDataSink for this DataSet. The data retrieved from the defined data sources will be written to the defined DataSink.
        Parameters:
        target - the output stream to write to
        delimiter -
        formatType -
      • addDataSink

        public void addDataSink​(DataSink sink)
        Adds a DataSink directly to this DataSetBuilder.
        Parameters:
        sink - the DataSink to add