com.orientechnologies.orient.stresstest.workload

Class OBaseWorkload

java.lang.Object

com.orientechnologies.orient.stresstest.workload.OBaseWorkload

All Implemented Interfaces:

OWorkload

Direct Known Subclasses:

OBaseDocumentWorkload, OBaseGraphWorkload

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 and Description
class	OBaseWorkload.OBaseWorkLoadContext
class	OBaseWorkload.OWorkLoadResult

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
OBaseWorkload()

Method Summary

Modifier and Type	Method and Description
protected abstract void	beginTransaction(OBaseWorkload.OBaseWorkLoadContext context)
protected abstract void	commitTransaction(OBaseWorkload.OBaseWorkLoadContext context)
protected List<OBaseWorkload.OBaseWorkLoadContext>	executeOperation(ODatabaseIdentifier dbIdentifier, 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 Detail

connectionStrategy

protected OStorageRemote.CONNECTION_STRATEGY connectionStrategy

MAX_ERRORS

protected static final long MAX_ERRORS

See Also:

Constant Field Values

errors

protected List<String> errors

Constructor Detail

OBaseWorkload

public OBaseWorkload()

Method Detail

executeOperation

protected List<OBaseWorkload.OBaseWorkLoadContext> executeOperation(ODatabaseIdentifier dbIdentifier,
                                                                    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)