com.fasterxml.transistore.cmd

Class GenerateLoad

java.lang.Object

com.fasterxml.transistore.cmd.TStoreCmdBase

com.fasterxml.transistore.cmd.GenerateLoad

All Implemented Interfaces:

Runnable

@Command(name="generate",
         description="Generate and upload test data in TStore")
public class GenerateLoad
extends TStoreCmdBase

Field Summary

Fields

Modifier and Type	Field and Description
protected BasicTSClient	_client
protected BasicTSKey	_prefix
protected long	_startTime
List<String>	arguments
int	requestCount
long	requestSize
protected static long	THREAD_STARTUP_DELAY_MSECS Number of milliseconds between creating new threads during startup
int	threadCount

Fields inherited from class com.fasterxml.transistore.cmd.TStoreCmdBase

_canPrintVerbose, configFile, isJSON, isTextual, KEY_CONVERTER, mapper, servers, SLASH_PATTERN, verbose

Constructor Summary

Constructors

Constructor and Description
GenerateLoad()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	_logPut(com.fasterxml.clustermate.client.operation.PutOperationResult result, String threadId, int msecs, String key)
protected boolean	_performOperation(String threadId, com.fasterxml.transistore.cmd.GenerateLoad.ContentGenerator gen)
protected BasicTSClientConfig	getClientConfig()
void	run()

Methods inherited from class com.fasterxml.transistore.cmd.TStoreCmdBase

_pathFrom, appendPath, bootstrapClient, contentKey, contentKey, contentKey, error, getServiceConfig, jsonGenerator, jsonWriter, pathFromFile, terminateWith, warn

Methods inherited from class java.lang.Object

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

Field Detail

THREAD_STARTUP_DELAY_MSECS

protected static final long THREAD_STARTUP_DELAY_MSECS

Number of milliseconds between creating new threads during startup

See Also:

Constant Field Values

threadCount

public int threadCount

requestCount

public int requestCount

requestSize

public long requestSize

arguments

public List<String> arguments

_client

protected BasicTSClient _client

_prefix

protected BasicTSKey _prefix

_startTime

protected long _startTime

Constructor Detail

GenerateLoad

public GenerateLoad()

Method Detail

getClientConfig

protected BasicTSClientConfig getClientConfig()

Overrides:

getClientConfig in class TStoreCmdBase

run

public void run()

_performOperation

protected boolean _performOperation(String threadId,
                        com.fasterxml.transistore.cmd.GenerateLoad.ContentGenerator gen)
                             throws Exception

Throws:

Exception

_logPut

protected void _logPut(com.fasterxml.clustermate.client.operation.PutOperationResult result,
           String threadId,
           int msecs,
           String key)