org.databene.benerator.engine.statement
Class GenerateOrIterateStatement

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

public class GenerateOrIterateStatement
extends AbstractStatement
implements GeneratorStatement, PageListener

Creates a number of entities in parallel execution and a given page size.

Created: 01.02.2008 14:43:15

Author:
Volker Bergmann

Field Summary
protected  Generator<java.lang.Long> countGenerator
           
protected  boolean infoLog
           
protected  boolean initialized
           
protected  boolean isSubCreator
           
protected  org.databene.commons.Expression<java.lang.Long> minCount
           
protected  PageListener pageListener
           
protected  org.databene.commons.Expression<PageListener> pageListenerEx
           
protected  org.databene.commons.Expression<java.lang.Long> pageSize
           
protected  GeneratorTask task
           
protected  org.databene.commons.Expression<java.lang.Integer> threads
           
protected  org.databene.contiperf.PerformanceTracker tracker
           
 
Constructor Summary
GenerateOrIterateStatement(GeneratorTask task, Generator<java.lang.Long> countGenerator, org.databene.commons.Expression<java.lang.Long> minCount, org.databene.commons.Expression<java.lang.Long> pageSize, org.databene.commons.Expression<PageListener> pageListenerEx, org.databene.commons.Expression<java.lang.Integer> threads, org.databene.commons.Expression<org.databene.commons.ErrorHandler> errorHandler, boolean infoLog, boolean isSubCreator)
           
 
Method Summary
 void close()
           
 void execute(BeneratorContext context)
           
 java.lang.Long generateCount(GeneratorContext context)
           
 GeneratorTask getTarget()
           
 org.databene.contiperf.PerformanceTracker getTracker()
           
 void pageFinished()
           
 void pageStarting()
           
 void prepare(GeneratorContext context)
           
 void setTask(GeneratorTask task)
           
 
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

task

protected GeneratorTask task

countGenerator

protected Generator<java.lang.Long> countGenerator

minCount

protected org.databene.commons.Expression<java.lang.Long> minCount

pageSize

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

threads

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

pageListenerEx

protected org.databene.commons.Expression<PageListener> pageListenerEx

pageListener

protected PageListener pageListener

tracker

protected org.databene.contiperf.PerformanceTracker tracker

infoLog

protected boolean infoLog

isSubCreator

protected boolean isSubCreator

initialized

protected boolean initialized
Constructor Detail

GenerateOrIterateStatement

public GenerateOrIterateStatement(GeneratorTask task,
                                  Generator<java.lang.Long> countGenerator,
                                  org.databene.commons.Expression<java.lang.Long> minCount,
                                  org.databene.commons.Expression<java.lang.Long> pageSize,
                                  org.databene.commons.Expression<PageListener> pageListenerEx,
                                  org.databene.commons.Expression<java.lang.Integer> threads,
                                  org.databene.commons.Expression<org.databene.commons.ErrorHandler> errorHandler,
                                  boolean infoLog,
                                  boolean isSubCreator)
Method Detail

setTask

public void setTask(GeneratorTask task)

execute

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

prepare

public void prepare(GeneratorContext context)
Specified by:
prepare in interface GeneratorStatement

close

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

generateCount

public java.lang.Long generateCount(GeneratorContext context)
Specified by:
generateCount in interface GeneratorStatement

getTarget

public GeneratorTask getTarget()
Specified by:
getTarget in interface GeneratorStatement

getTracker

public org.databene.contiperf.PerformanceTracker getTracker()

pageStarting

public void pageStarting()
Specified by:
pageStarting in interface PageListener

pageFinished

public void pageFinished()
Specified by:
pageFinished in interface PageListener


Copyright © 2011. All Rights Reserved.