com.datastax.oss.dsbulk.executor.api.listener

Class DefaultExecutionContext

java.lang.Object

com.datastax.oss.dsbulk.executor.api.listener.DefaultExecutionContext

All Implemented Interfaces:

ExecutionContext

public class DefaultExecutionContext
extends Object
implements ExecutionContext

Constructor Summary

Constructors

Constructor and Description
DefaultExecutionContext()

Method Summary

Modifier and Type	Method and Description
long	elapsedTimeNanos() Returns the elapsed time, in nanoseconds, between start and end of execution.
Optional<Object>	getAttribute(Object key) Retrieves an attribute stored in this context.
void	setAttribute(Object key, Object value) Sets an attribute into this context.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultExecutionContext

public DefaultExecutionContext()

Method Detail

setAttribute

public void setAttribute(Object key,
                         Object value)

Description copied from interface: ExecutionContext

Sets an attribute into this context.

Specified by:

setAttribute in interface ExecutionContext

Parameters:

key - the attribute key. Cannot be null.

value - the attribute value. Can be null.

getAttribute

public Optional<Object> getAttribute(Object key)

Description copied from interface: ExecutionContext

Retrieves an attribute stored in this context.

Specified by:

getAttribute in interface ExecutionContext

Parameters:

key - the attribute key. Cannot be null.

Returns:

an Optional containing the attribute value, if present.

elapsedTimeNanos

public long elapsedTimeNanos()

Description copied from interface: ExecutionContext

Returns the elapsed time, in nanoseconds, between start and end of execution.

The exact meaning of the value returned by this method depends on whether the context is global or local: for global contexts, this is the elapsed time for the whole statement execution; for local ones, this is the elapsed time for a single request-response cycle.

Specified by:

elapsedTimeNanos in interface ExecutionContext

Returns:

the elapsed time, in nanoseconds, between start and end of execution; or -1, if the execution hasn't finished yet.

start

public void start()

stop

public void stop()