org.apache.hadoop.hbase.client

Class TestBufferedMutator.MyBufferedMutator

java.lang.Object

org.apache.hadoop.hbase.client.BufferedMutatorImpl

org.apache.hadoop.hbase.client.TestBufferedMutator.MyBufferedMutator

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.client.BufferedMutator

Enclosing class:

TestBufferedMutator

public static class TestBufferedMutator.MyBufferedMutator
extends org.apache.hadoop.hbase.client.BufferedMutatorImpl

My BufferedMutator. Just to prove that I can insert a BM other than default.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.client.BufferedMutatorImpl

org.apache.hadoop.hbase.client.BufferedMutatorImpl.QueueRowAccess

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

org.apache.hadoop.hbase.client.BufferedMutator.ExceptionListener

Field Summary

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

CLASSNAME_KEY, MIN_WRITE_BUFFER_PERIODIC_FLUSH_TIMERTICK_MS

Constructor Summary

Constructors

Constructor and Description
MyBufferedMutator(org.apache.hadoop.hbase.client.ClusterConnection conn, org.apache.hadoop.hbase.client.RpcRetryingCallerFactory rpcCallerFactory, org.apache.hadoop.hbase.ipc.RpcControllerFactory rpcFactory, org.apache.hadoop.hbase.client.BufferedMutatorParams params)

Method Summary

Methods inherited from class org.apache.hadoop.hbase.client.BufferedMutatorImpl

close, createQueueRowAccess, flush, getAsyncProcess, getConfiguration, getCurrentWriteBufferSize, getExecutedWriteBufferPeriodicFlushes, getName, getPool, getUnflushedSize, getWriteBufferPeriodicFlushTimeoutMs, getWriteBufferPeriodicFlushTimerTickMs, getWriteBufferSize, mutate, mutate, setOperationTimeout, setRpcTimeout, setWriteBufferPeriodicFlush, size

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, setWriteBufferPeriodicFlush

Constructor Detail

MyBufferedMutator

MyBufferedMutator(org.apache.hadoop.hbase.client.ClusterConnection conn,
                  org.apache.hadoop.hbase.client.RpcRetryingCallerFactory rpcCallerFactory,
                  org.apache.hadoop.hbase.ipc.RpcControllerFactory rpcFactory,
                  org.apache.hadoop.hbase.client.BufferedMutatorParams params)