com.splicemachine.derby.stream.output

Class PermissiveInsertWriteConfiguration

java.lang.Object

com.splicemachine.pipeline.config.ForwardingWriteConfiguration

com.splicemachine.derby.stream.output.PermissiveInsertWriteConfiguration

All Implemented Interfaces:

WriteConfiguration

public class PermissiveInsertWriteConfiguration
extends ForwardingWriteConfiguration

Field Summary

Fields

Modifier and Type	Field and Description
protected OperationContext	operationContext
protected java.lang.ThreadLocal<PairDecoder>	pairDecoder

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

delegate

Constructor Summary

Constructors

Constructor and Description
PermissiveInsertWriteConfiguration(WriteConfiguration delegate, OperationContext operationContext, PairEncoder encoder, ExecRow execRowDefinition)

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

Field Detail

operationContext

protected OperationContext operationContext

pairDecoder

protected java.lang.ThreadLocal<PairDecoder> pairDecoder

Constructor Detail

PermissiveInsertWriteConfiguration

public PermissiveInsertWriteConfiguration(WriteConfiguration delegate,
                                          OperationContext operationContext,
                                          PairEncoder encoder,
                                          ExecRow execRowDefinition)

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