org.databene.benerator.engine.statement
Class GenerateAndConsumeTask
java.lang.Object
org.databene.benerator.engine.statement.GenerateAndConsumeTask
- All Implemented Interfaces:
- java.io.Closeable, ResourceManager, org.databene.commons.MessageHolder, org.databene.commons.ThreadAware, PageListener, Task
public class GenerateAndConsumeTask
- extends java.lang.Object
- implements Task, PageListener, ResourceManager, org.databene.commons.MessageHolder
Task that creates one data set instance per run() invocation and sends it to the specified consumer.
Created: 01.02.2008 14:39:11
- Author:
- Volker Bergmann
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
statements
protected java.util.List<Statement> statements
GenerateAndConsumeTask
public GenerateAndConsumeTask(java.lang.String taskName,
java.lang.String productName)
addStatement
public void addStatement(Statement statement)
setStatements
public void setStatements(java.util.List<Statement> statements)
getResourceManager
public ResourceManager getResourceManager()
setConsumer
public void setConsumer(org.databene.script.Expression<Consumer> consumerExpr)
getConsumer
public Consumer getConsumer()
init
public void init(BeneratorContext context)
getProductName
public java.lang.String getProductName()
getRecentProduct
public ProductWrapper<?> getRecentProduct()
getTaskName
public java.lang.String getTaskName()
- Specified by:
getTaskName
in interface Task
- Returns:
- the name of the task.
isThreadSafe
public boolean isThreadSafe()
- Specified by:
isThreadSafe
in interface org.databene.commons.ThreadAware
isParallelizable
public boolean isParallelizable()
- Specified by:
isParallelizable
in interface org.databene.commons.ThreadAware
execute
public TaskResult execute(org.databene.commons.Context ctx,
org.databene.commons.ErrorHandler errorHandler)
- Description copied from interface:
Task
- Executes the task's work, possibly interacting with the context.
- Specified by:
execute
in interface Task
reset
public void reset()
close
public void close()
- Specified by:
close
in interface java.io.Closeable
- Specified by:
close
in interface ResourceManager
- Specified by:
close
in interface Task
pageStarting
public void pageStarting()
- Specified by:
pageStarting
in interface PageListener
pageFinished
public void pageFinished()
- Specified by:
pageFinished
in interface PageListener
- Specified by:
pageFinished
in interface Task
addResource
public boolean addResource(java.io.Closeable resource)
- Specified by:
addResource
in interface ResourceManager
getMessage
public java.lang.String getMessage()
- Specified by:
getMessage
in interface org.databene.commons.MessageHolder
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
initStatements
public void initStatements(BeneratorContext context)
Copyright © 2013. All Rights Reserved.