com.splicemachine.pipeline.config

Class CountingWriteConfiguration

java.lang.Object

com.splicemachine.pipeline.config.ForwardingWriteConfiguration

com.splicemachine.pipeline.config.CountingWriteConfiguration

All Implemented Interfaces:

WriteConfiguration

public class CountingWriteConfiguration
extends ForwardingWriteConfiguration

Field Summary

Fields inherited from class com.splicemachine.pipeline.config.ForwardingWriteConfiguration

delegate

Constructor Summary

Constructors

Constructor and Description
CountingWriteConfiguration(WriteConfiguration writeConfiguration, ActionStatusReporter statusMonitor, PipelineExceptionFactory exceptionFactory)

Method Summary

Modifier and Type	Method and Description
WriteResponse	globalError(java.lang.Throwable t)
WriteResponse	partialFailure(BulkWriteResult result, BulkWrite request)
WriteResponse	processGlobalResult(BulkWriteResult bulkWriteResult)
java.lang.String	toString()

Methods inherited from class com.splicemachine.pipeline.config.ForwardingWriteConfiguration

getExceptionFactory, getMaximumRetries, getMetricFactory, getPause, getRecordingContext, registerContext, setRecordingContext, skipConflictDetection, skipWAL, writeComplete

Methods inherited from class java.lang.Object

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

Constructor Detail

CountingWriteConfiguration

public CountingWriteConfiguration(WriteConfiguration writeConfiguration,
                                  ActionStatusReporter statusMonitor,
                                  PipelineExceptionFactory exceptionFactory)

Method Detail

globalError

public WriteResponse globalError(java.lang.Throwable t)
                          throws java.util.concurrent.ExecutionException

Specified by:

globalError in interface WriteConfiguration

Overrides:

globalError in class ForwardingWriteConfiguration

Throws:

java.util.concurrent.ExecutionException

processGlobalResult

public WriteResponse processGlobalResult(BulkWriteResult bulkWriteResult)
                                  throws java.lang.Throwable

Specified by:

processGlobalResult in interface WriteConfiguration

Overrides:

processGlobalResult in class ForwardingWriteConfiguration

Throws:

java.lang.Throwable

partialFailure

public WriteResponse partialFailure(BulkWriteResult result,
                                    BulkWrite request)
                             throws java.util.concurrent.ExecutionException

Specified by:

partialFailure in interface WriteConfiguration

Overrides:

partialFailure in class ForwardingWriteConfiguration

Throws:

java.util.concurrent.ExecutionException

toString

public java.lang.String toString()

Overrides:

toString in class ForwardingWriteConfiguration