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

Constructor Summary

Constructors

Constructor	Description
DataSet(T configuration)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 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 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