Package step.datapool

Class DataSet<T extends DataPoolConfiguration>

java.lang.Object
step.datapool.DataSet<T>
Direct Known Subclasses:
ExcelDataPoolImpl, FileDataPoolImpl, FileReaderDataPool, GoogleSheetv4DataPool, IntSequenceDataPoolImpl, JsonArrayDataPoolImpl, JsonStringDataPoolImpl, SQLTableDataPool
public abstract class DataSet<T extends DataPoolConfiguration> extends Object

  • Field Details

    • configuration

      protected final T extends DataPoolConfiguration configuration

    • context

      protected ExecutionContext context

    • isRowCommitEnabled

      protected boolean isRowCommitEnabled

    • closing

      protected volatile boolean closing

  • Constructor Details

    • DataSet

      public DataSet(T configuration)

  • Method Details

    • enableRowCommit

      public void enableRowCommit(boolean rowCommit)
      Parameters:
      rowCommit - if the row commit is enabled. IMPORTANT: If row commit is enabled, it is the responsibility of the user to call the method DataPoolRow.commit() after the row has been processed If the method DataPoolRow.commit() isn't called, closing the DataSet may block indefinitely

    • init

      public void init()

    • reset

      public abstract void reset()

    • close

      public void close()

    • isWriteQueueSupportEnabled

      protected boolean isWriteQueueSupportEnabled()

    • next

      public final DataPoolRow next()

    • next_

      public abstract Object next_()

    • addRow

      public abstract void addRow(Object row)

    • save

      public void save()

    • setContext

      protected void setContext(ExecutionContext context)

    • writeRow

      public void writeRow(DataPoolRow row) throws IOException
      Throws:
      IOException