Package com.orientechnologies.orient.stresstest.workload

Class OBaseWorkload

java.lang.Object

com.orientechnologies.orient.stresstest.workload.OBaseWorkload

All Implemented Interfaces:

OWorkload

Direct Known Subclasses:

OBaseDocumentWorkload

public abstract class OBaseWorkload
extends Object
implements OWorkload

CRUD implementation of the workload.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	OBaseWorkload.OBaseWorkLoadContext
class	OBaseWorkload.OWorkLoadResult

Field Summary

Fields

Modifier and Type	Field	Description
protected ORemoteClient.CONNECTION_STRATEGY	connectionStrategy
protected List<String>	errors
protected static final long	MAX_ERRORS

Constructor Summary

Constructors

Constructor	Description
OBaseWorkload()

Method Summary

Modifier and Type	Method	Description
protected abstract void	beginTransaction(OBaseWorkload.OBaseWorkLoadContext context)
protected abstract void	commitTransaction(OBaseWorkload.OBaseWorkLoadContext context)
protected List<OBaseWorkload.OBaseWorkLoadContext>	executeOperation(OrientDB ctx, OBaseWorkload.OWorkLoadResult result, OStressTesterSettings settings, OCallable<Void,OBaseWorkload.OBaseWorkLoadContext> callback)
protected abstract OBaseWorkload.OBaseWorkLoadContext	getContext()
protected String	getErrors()
protected int	getPercentile(Long[] sortedResults, long time)
protected void	manageNeedRetryException(OBaseWorkload.OBaseWorkLoadContext context, ONeedRetryException e)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.stresstest.workload.OWorkload

execute, getFinalResult, getFinalResultAsJson, getName, getPartialResult, parseParameters

Field Details

connectionStrategy

protected ORemoteClient.CONNECTION_STRATEGY connectionStrategy

MAX_ERRORS

protected static final long MAX_ERRORS

See Also:

• Constant Field Values

errors

protected List<String> errors

Constructor Details

OBaseWorkload

public OBaseWorkload()

Method Details

executeOperation

protected List<OBaseWorkload.OBaseWorkLoadContext> executeOperation(OrientDB ctx,
 OBaseWorkload.OWorkLoadResult result,
 OStressTesterSettings settings,
 OCallable<Void,OBaseWorkload.OBaseWorkLoadContext> callback)

manageNeedRetryException

protected void manageNeedRetryException(OBaseWorkload.OBaseWorkLoadContext context,
 ONeedRetryException e)

beginTransaction

protected abstract void beginTransaction(OBaseWorkload.OBaseWorkLoadContext context)

commitTransaction

protected abstract void commitTransaction(OBaseWorkload.OBaseWorkLoadContext context)

getContext

protected abstract OBaseWorkload.OBaseWorkLoadContext getContext()

getErrors

protected String getErrors()

getPercentile

protected int getPercentile(Long[] sortedResults,
 long time)