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 java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description protected boolean
closing
protected T
configuration
protected ExecutionContext
context
protected boolean
isRowCommitEnabled
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract void
addRow(java.lang.Object row)
void
close()
void
enableRowCommit(boolean rowCommit)
void
init()
protected boolean
isWriteQueueSupportEnabled()
DataPoolRow
next()
abstract java.lang.Object
next_()
abstract void
reset()
void
save()
protected void
setContext(ExecutionContext context)
void
writeRow(DataPoolRow row)
-
-
-
Field Detail
-
configuration
protected final T extends DataPoolConfiguration configuration
-
context
protected ExecutionContext context
-
isRowCommitEnabled
protected boolean isRowCommitEnabled
-
closing
protected volatile boolean closing
-
-
Constructor Detail
-
DataSet
public DataSet(T configuration)
-
-
Method Detail
-
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 methodDataPoolRow.commit()
after the row has been processed If the methodDataPoolRow.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 java.lang.Object next_()
-
addRow
public abstract void addRow(java.lang.Object row)
-
save
public void save()
-
setContext
protected void setContext(ExecutionContext context)
-
writeRow
public void writeRow(DataPoolRow row) throws java.io.IOException
- Throws:
java.io.IOException
-
-