Modifier and Type | Method and Description |
---|---|
<T extends Options> |
XmlProgressListener.afterOperation(Runner<T> runner,
T options,
Operation operation,
OperationRun run) |
<T extends Options> |
StreamProgressListener.afterOperation(Runner<T> runner,
T options,
Operation operation,
OperationRun run) |
<T extends Options> |
ProgressListener.afterOperation(Runner<T> runner,
T options,
Operation operation,
OperationRun run)
Invoked after each run of an operation
|
<T extends Options> |
CsvProgressListener.afterOperation(Runner<T> runner,
T options,
Operation operation,
OperationRun run)
Does nothing as this listener discards individual operation run
statistics
|
Modifier and Type | Method and Description |
---|---|
OperationRun |
Operation.createErrorInformation(String message,
int category,
long runtime)
Creates run information for an error
|
Modifier and Type | Method and Description |
---|---|
OperationRun |
AbstractGSPCallable.call() |
OperationRun |
AbstractGSPOperation.createErrorInformation(String message,
int category,
long runtime) |
Modifier and Type | Method and Description |
---|---|
OperationRun |
InMemoryFixedUpdateOperation.createErrorInformation(String message,
int category,
long runtime) |
OperationRun |
FixedUpdateOperation.createErrorInformation(String message,
int category,
long runtime) |
Modifier and Type | Method and Description |
---|---|
OperationRun |
SleepCallable.call() |
OperationRun |
NoOpCallable.call() |
OperationRun |
MixOperationCallable.call() |
OperationRun |
SleepOperation.createErrorInformation(String message,
int category,
long runtime) |
OperationRun |
MixOperation.createErrorInformation(String message,
int category,
long runtime) |
Constructor and Description |
---|
NoOpCallable(Runner<T> runner,
T options,
OperationRun runInfo)
Creates a new callable
|
Modifier and Type | Method and Description |
---|---|
protected OperationRun |
AbstractRunner.runOp(T options,
Operation op)
Runs an operation using the configured operation runner, if there is no
configured runner then it uses the
DefaultOperationRunner to run
the operation. |
Modifier and Type | Method and Description |
---|---|
void |
Runner.reportAfterOperation(T options,
Operation operation,
OperationRun run)
Reports progress after we have run an operation
|
void |
AbstractRunner.reportAfterOperation(T options,
Operation operation,
OperationRun run) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractRunner.reportCategorizedErrors(T options,
Map<Integer,List<OperationRun>> categorizedErrors)
Reports categorized errors
|
Modifier and Type | Method and Description |
---|---|
protected <T extends Options> |
AbstractOperationMixRunner.runOp(Runner<T> runner,
T options,
Operation op)
Runs an operation based on the configured
OperationRunner using
the DefaultOperationRunner if none is configured |
Modifier and Type | Method and Description |
---|---|
<T extends Options> |
RetryingOperationRunner.run(Runner<T> runner,
T options,
Operation op) |
<T extends Options> |
OperationRunner.run(Runner<T> runner,
T options,
Operation op)
Runs the operation returning the statistics as an
OperationRun |
<T extends Options> |
DefaultOperationRunner.run(Runner<T> runner,
T options,
Operation op) |
Modifier and Type | Method and Description |
---|---|
protected <T extends Options> |
RetryingOperationRunner.shouldRetry(Runner<T> runner,
T options,
Operation op,
OperationRun run)
Decides whether the runner should continue retrying
|
Modifier and Type | Method and Description |
---|---|
Map<Integer,List<OperationRun>> |
OperationStats.getCategorizedErrors()
Gets the information for all errors grouped by category
|
Map<Integer,List<OperationRun>> |
OperationMixStats.getCategorizedErrors()
Gets the information for all errors grouped by category
|
Iterator<OperationRun> |
OperationStats.getRuns()
Gets an iterator over the operation runs
|
Iterator<OperationRun> |
OperationMixRun.getRuns()
Gets an iterator over the runs that make up this operation mix
|
List<OperationRun> |
OperationMixRun.getRuns(int id)
Gets the list of run information for the given operation ID, if there are
no runs for that given operation within this mix run then an empty list
is returned.
|
Modifier and Type | Method and Description |
---|---|
void |
OperationStats.add(OperationRun run)
Adds information for the given run to the statistics
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractOperationRun
Abstract implementation of an operation run
|
class |
OperationRunImpl
A general purpose operation run implementation
|
class |
QueryRun
Represents a run of a single query
|
class |
UpdateRun
Statistics for an update run
|
Modifier and Type | Field and Description |
---|---|
protected List<OperationRun> |
OperationMixRunImpl.runs |
Modifier and Type | Method and Description |
---|---|
Map<Integer,List<OperationRun>> |
OperationStatsImpl.getCategorizedErrors() |
Map<Integer,List<OperationRun>> |
OperationMixStatsImpl.getCategorizedErrors() |
Iterator<OperationRun> |
OperationStatsImpl.getRuns() |
Iterator<OperationRun> |
OperationMixRunImpl.getRuns() |
List<OperationRun> |
OperationMixRunImpl.getRuns(int id) |
Modifier and Type | Method and Description |
---|---|
void |
OperationStatsImpl.add(OperationRun run) |
int |
AbstractOperationRun.compareTo(OperationRun other)
Compares a run to another
|
Constructor and Description |
---|
OperationMixRunImpl(Collection<OperationRun> runs,
long runOrder)
Creates a new operation mix run which represents the results of running a
mix of operations
|
Copyright © 2015. All rights reserved.