org.databene.benerator.engine.statement
Class RunTaskStatement

java.lang.Object
  extended by org.databene.benerator.engine.statement.AbstractStatement
      extended by org.databene.benerator.engine.statement.RunTaskStatement
All Implemented Interfaces:
java.io.Closeable, Statement

public class RunTaskStatement
extends AbstractStatement
implements java.io.Closeable

Statement that executes a Task supporting paging and multithreading.

Created: 27.10.2009 20:29:47

Since:
0.6.0
Author:
Volker Bergmann

Field Summary
protected  org.databene.script.Expression<java.lang.Long> count
           
protected  org.databene.script.Expression<org.databene.commons.ErrorHandler> errorHandler
           
protected  boolean infoLog
           
protected  org.databene.script.Expression<PageListener> pageListener
           
protected  org.databene.script.Expression<java.lang.Long> pageSize
           
protected  org.databene.script.Expression<java.lang.Boolean> stats
           
protected  Task task
           
protected  org.databene.script.Expression<? extends Task> taskProvider
           
protected  org.databene.script.Expression<java.lang.Integer> threads
           
 
Constructor Summary
RunTaskStatement(org.databene.script.Expression<? extends Task> taskProvider, org.databene.script.Expression<java.lang.Long> count, org.databene.script.Expression<java.lang.Long> pageSize, org.databene.script.Expression<PageListener> pageListener, org.databene.script.Expression<java.lang.Integer> threads, org.databene.script.Expression<java.lang.Boolean> stats, org.databene.script.Expression<org.databene.commons.ErrorHandler> errorHandler, boolean infoLog)
           
 
Method Summary
 void close()
           
 boolean execute(BeneratorContext context)
           
 org.databene.script.Expression<java.lang.Long> getCount()
           
 org.databene.script.Expression<PageListener> getPager()
           
 org.databene.script.Expression<java.lang.Long> getPageSize()
           
 Task getTask(BeneratorContext context)
           
 org.databene.script.Expression<java.lang.Integer> getThreads()
           
 
Methods inherited from class org.databene.benerator.engine.statement.AbstractStatement
cache, getErrorHandler, handleError, handleError, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

taskProvider

protected org.databene.script.Expression<? extends Task> taskProvider

task

protected Task task

count

protected org.databene.script.Expression<java.lang.Long> count

pageSize

protected org.databene.script.Expression<java.lang.Long> pageSize

threads

protected org.databene.script.Expression<java.lang.Integer> threads

pageListener

protected org.databene.script.Expression<PageListener> pageListener

stats

protected org.databene.script.Expression<java.lang.Boolean> stats

errorHandler

protected org.databene.script.Expression<org.databene.commons.ErrorHandler> errorHandler

infoLog

protected boolean infoLog
Constructor Detail

RunTaskStatement

public RunTaskStatement(org.databene.script.Expression<? extends Task> taskProvider,
                        org.databene.script.Expression<java.lang.Long> count,
                        org.databene.script.Expression<java.lang.Long> pageSize,
                        org.databene.script.Expression<PageListener> pageListener,
                        org.databene.script.Expression<java.lang.Integer> threads,
                        org.databene.script.Expression<java.lang.Boolean> stats,
                        org.databene.script.Expression<org.databene.commons.ErrorHandler> errorHandler,
                        boolean infoLog)
Method Detail

getCount

public org.databene.script.Expression<java.lang.Long> getCount()

getPageSize

public org.databene.script.Expression<java.lang.Long> getPageSize()

getThreads

public org.databene.script.Expression<java.lang.Integer> getThreads()

getPager

public org.databene.script.Expression<PageListener> getPager()

execute

public boolean execute(BeneratorContext context)
Specified by:
execute in interface Statement

getTask

public Task getTask(BeneratorContext context)

close

public void close()
Specified by:
close in interface java.io.Closeable


Copyright © 2013. All Rights Reserved.