Package org.apache.hadoop.hbase.client

Class BufferedMutatorOverAsyncBufferedMutator

java.lang.Object

org.apache.hadoop.hbase.client.BufferedMutatorOverAsyncBufferedMutator

All Implemented Interfaces:

Closeable, AutoCloseable, BufferedMutator

@Private
class BufferedMutatorOverAsyncBufferedMutator
extends Object
implements BufferedMutator

BufferedMutator implementation based on AsyncBufferedMutator.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.client.BufferedMutator

BufferedMutator.ExceptionListener

Field Summary

Fields

Modifier and Type	Field	Description
private static final Pattern	ADDR_MSG_MATCHER
private final AtomicLong	bufferedSize
private final ConcurrentLinkedQueue<Pair<Mutation,Throwable>>	errors
private final Set<CompletableFuture<Void>>	futures
private final BufferedMutator.ExceptionListener	listener
private static final org.slf4j.Logger	LOG
private final AsyncBufferedMutator	mutator

Fields inherited from interface org.apache.hadoop.hbase.client.BufferedMutator

CLASSNAME_KEY, MIN_WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS

Constructor Summary

Constructors

Constructor	Description
BufferedMutatorOverAsyncBufferedMutator(AsyncBufferedMutator mutator, BufferedMutator.ExceptionListener listener)

Method Summary

Modifier and Type	Method	Description
void	close()	Performs a BufferedMutator.flush() and releases any resources held.
void	flush()	Executes all the buffered, asynchronous Mutation operations and waits until they are done.
org.apache.hadoop.conf.Configuration	getConfiguration()	Returns the Configuration object used by this instance.
private String	getHostnameAndPort(Throwable error)
TableName	getName()	Gets the fully qualified table name instance of the table that this BufferedMutator writes to.
Map<String,byte[]>	getRequestAttributes()	Returns the rpc request attributes.
long	getWriteBufferSize()	Returns the maximum size in bytes of the write buffer for this HTable.
private void	internalFlush()
private RetriesExhaustedWithDetailsException	makeError()
void	mutate(List<? extends Mutation> mutations)	Send some Mutations to the table.
void	mutate(Mutation mutation)	Sends a Mutation to the table.
void	setOperationTimeout(int timeout)	Set operation timeout for this mutator instance
void	setRpcTimeout(int timeout)	Set rpc timeout for this mutator instance

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.client.BufferedMutator

disableWriteBufferPeriodicFlush, getWriteBufferPeriodicFlushTimeoutMs, getWriteBufferPeriodicFlushTimerTickMs, setWriteBufferPeriodicFlush, setWriteBufferPeriodicFlush

Field Details

LOG

private static final org.slf4j.Logger LOG

mutator

private final AsyncBufferedMutator mutator

listener

private final BufferedMutator.ExceptionListener listener

futures

private final Set<CompletableFuture<Void>> futures

bufferedSize

private final AtomicLong bufferedSize

errors

private final ConcurrentLinkedQueue<Pair<Mutation,Throwable>> errors

ADDR_MSG_MATCHER

private static final Pattern ADDR_MSG_MATCHER

Constructor Details

BufferedMutatorOverAsyncBufferedMutator

BufferedMutatorOverAsyncBufferedMutator(AsyncBufferedMutator mutator,
 BufferedMutator.ExceptionListener listener)

Method Details

getName

public TableName getName()

Description copied from interface: BufferedMutator

Gets the fully qualified table name instance of the table that this BufferedMutator writes to.

Specified by:

getName in interface BufferedMutator

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Description copied from interface: BufferedMutator

Returns the Configuration object used by this instance.

The reference returned is not a copy, so any change made to it will affect this instance.

Specified by:

getConfiguration in interface BufferedMutator

mutate

public void mutate(Mutation mutation)
            throws IOException

Description copied from interface: BufferedMutator

Sends a Mutation to the table. The mutations will be buffered and sent over the wire as part of a batch. Currently only supports Put and Delete mutations.

Specified by:

mutate in interface BufferedMutator

Parameters:

mutation - The data to send.

Throws:

IOException - if a remote or network exception occurs.

getHostnameAndPort

private String getHostnameAndPort(Throwable error)

makeError

private RetriesExhaustedWithDetailsException makeError()

internalFlush

private void internalFlush()
                    throws RetriesExhaustedWithDetailsException

Throws:

RetriesExhaustedWithDetailsException

mutate

public void mutate(List<? extends Mutation> mutations)
            throws IOException

Description copied from interface: BufferedMutator

Send some Mutations to the table. The mutations will be buffered and sent over the wire as part of a batch. There is no guarantee of sending entire content of mutations in a single batch; it will be broken up according to the write buffer capacity.

Specified by:

mutate in interface BufferedMutator

Parameters:

mutations - The data to send.

Throws:

IOException - if a remote or network exception occurs.

close

public void close()
           throws IOException

Description copied from interface: BufferedMutator

Performs a BufferedMutator.flush() and releases any resources held.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface BufferedMutator

Specified by:

close in interface Closeable

Throws:

IOException - if a remote or network exception occurs.

flush

public void flush()
           throws IOException

Description copied from interface: BufferedMutator

Executes all the buffered, asynchronous Mutation operations and waits until they are done.

Specified by:

flush in interface BufferedMutator

Throws:

IOException - if a remote or network exception occurs.

getWriteBufferSize

public long getWriteBufferSize()

Description copied from interface: BufferedMutator

Returns the maximum size in bytes of the write buffer for this HTable.

The default value comes from the configuration parameter hbase.client.write.buffer.

Specified by:

getWriteBufferSize in interface BufferedMutator

Returns:

The size of the write buffer in bytes.

setRpcTimeout

public void setRpcTimeout(int timeout)

Description copied from interface: BufferedMutator

Set rpc timeout for this mutator instance

Specified by:

setRpcTimeout in interface BufferedMutator

setOperationTimeout

public void setOperationTimeout(int timeout)

Description copied from interface: BufferedMutator

Set operation timeout for this mutator instance

Specified by:

setOperationTimeout in interface BufferedMutator

getRequestAttributes

public Map<String,byte[]> getRequestAttributes()

Description copied from interface: BufferedMutator

Returns the rpc request attributes.

Specified by:

getRequestAttributes in interface BufferedMutator