Uses of Interface
com.datastax.oss.dsbulk.executor.api.listener.ExecutionContext

Packages that use ExecutionContext

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

Uses of ExecutionContext in com.datastax.oss.dsbulk.executor.api.listener

Classes in com.datastax.oss.dsbulk.executor.api.listener that implement ExecutionContext

Modifier and Type	Class and Description
class	DefaultExecutionContext

Methods in com.datastax.oss.dsbulk.executor.api.listener with parameters of type ExecutionContext

Modifier and Type	Method and Description
void	MetricsCollectingExecutionListener.onExecutionFailed(BulkExecutionException exception, ExecutionContext context)
default void	ExecutionListener.onExecutionFailed(BulkExecutionException exception, ExecutionContext context) Called when a statement execution has failed.
void	CompositeExecutionListener.onExecutionFailed(BulkExecutionException exception, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onExecutionFailed(BulkExecutionException exception, ExecutionContext context)
default void	ExecutionListener.onExecutionStarted(Statement<?> statement, ExecutionContext context) Called when a statement is about to be executed.
void	CompositeExecutionListener.onExecutionStarted(Statement<?> statement, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onExecutionStarted(Statement<?> statement, ExecutionContext context)
void	MetricsCollectingExecutionListener.onExecutionSuccessful(Statement<?> statement, ExecutionContext context)
default void	ExecutionListener.onExecutionSuccessful(Statement<?> statement, ExecutionContext context) Called when a statement has been successfully executed.
void	CompositeExecutionListener.onExecutionSuccessful(Statement<?> statement, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onExecutionSuccessful(Statement<?> statement, ExecutionContext context)
void	MetricsCollectingExecutionListener.onReadRequestFailed(Statement<?> statement, Throwable error, ExecutionContext context)
default void	ExecutionListener.onReadRequestFailed(Statement<?> statement, Throwable error, ExecutionContext context) Called when a read request has failed.
void	CompositeExecutionListener.onReadRequestFailed(Statement<?> statement, Throwable error, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onReadRequestFailed(Statement<?> statement, Throwable error, ExecutionContext context)
void	MetricsCollectingExecutionListener.onReadRequestStarted(Statement<?> statement, ExecutionContext context)
default void	ExecutionListener.onReadRequestStarted(Statement<?> statement, ExecutionContext context) Called when a read request is about to be sent.
void	CompositeExecutionListener.onReadRequestStarted(Statement<?> statement, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onReadRequestStarted(Statement<?> statement, ExecutionContext context)
void	MetricsCollectingExecutionListener.onReadRequestSuccessful(Statement<?> statement, ExecutionContext context)
default void	ExecutionListener.onReadRequestSuccessful(Statement<?> statement, ExecutionContext context) Called when a read request has been completed successfully.
void	CompositeExecutionListener.onReadRequestSuccessful(Statement<?> statement, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onReadRequestSuccessful(Statement<?> statement, ExecutionContext context)
void	MetricsCollectingExecutionListener.onRowReceived(Row row, ExecutionContext context)
default void	ExecutionListener.onRowReceived(Row row, ExecutionContext context) Called when a row has been successfully received.
void	CompositeExecutionListener.onRowReceived(Row row, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onRowReceived(Row row, ExecutionContext context)
void	MetricsCollectingExecutionListener.onWriteRequestFailed(Statement<?> statement, Throwable error, ExecutionContext context)
default void	ExecutionListener.onWriteRequestFailed(Statement<?> statement, Throwable error, ExecutionContext context) Called when a write request has failed.
void	CompositeExecutionListener.onWriteRequestFailed(Statement<?> statement, Throwable error, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onWriteRequestFailed(Statement<?> statement, Throwable error, ExecutionContext context)
void	MetricsCollectingExecutionListener.onWriteRequestStarted(Statement<?> statement, ExecutionContext context)
default void	ExecutionListener.onWriteRequestStarted(Statement<?> statement, ExecutionContext context) Called when a write request is about to be sent.
void	CompositeExecutionListener.onWriteRequestStarted(Statement<?> statement, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onWriteRequestStarted(Statement<?> statement, ExecutionContext context)
void	MetricsCollectingExecutionListener.onWriteRequestSuccessful(Statement<?> statement, ExecutionContext context)
default void	ExecutionListener.onWriteRequestSuccessful(Statement<?> statement, ExecutionContext context) Called when a write request has been completed successfully.
void	CompositeExecutionListener.onWriteRequestSuccessful(Statement<?> statement, ExecutionContext context)
void	AbstractMetricsReportingExecutionListener.onWriteRequestSuccessful(Statement<?> statement, ExecutionContext context)