org.apache.hadoop.hbase.client

Class TestAsyncBufferMutator.AsyncBufferMutatorForTest

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncBufferMutator.AsyncBufferMutatorForTest

All Implemented Interfaces:

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

Enclosing class:

TestAsyncBufferMutator

private static final class TestAsyncBufferMutator.AsyncBufferMutatorForTest
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private int	flushCount
(package private) org.apache.hbase.thirdparty.io.netty.util.Timeout	periodicFlushTask

Constructor Summary

Constructors

Constructor and Description
AsyncBufferMutatorForTest(org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer periodicalFlushTimer, org.apache.hadoop.hbase.client.AsyncTable<?> table, long writeBufferSize, long periodicFlushTimeoutNs)

Method Summary

Modifier and Type	Method and Description
void	close()
void	flush()
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.hbase.TableName	getName()
long	getPeriodicalFlushTimeout(TimeUnit arg0)
long	getWriteBufferSize()
protected void	internalFlush()
List<CompletableFuture<Void>>	mutate(List<? extends org.apache.hadoop.hbase.client.Mutation> arg0)

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.AsyncBufferedMutator

mutate

Field Detail

flushCount

private int flushCount

periodicFlushTask

org.apache.hbase.thirdparty.io.netty.util.Timeout periodicFlushTask

Constructor Detail

AsyncBufferMutatorForTest

AsyncBufferMutatorForTest(org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer periodicalFlushTimer,
                          org.apache.hadoop.hbase.client.AsyncTable<?> table,
                          long writeBufferSize,
                          long periodicFlushTimeoutNs)

Method Detail

internalFlush

protected void internalFlush()

getName

public org.apache.hadoop.hbase.TableName getName()

Specified by:

getName in interface org.apache.hadoop.hbase.client.AsyncBufferedMutator

getConfiguration

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

Specified by:

getConfiguration in interface org.apache.hadoop.hbase.client.AsyncBufferedMutator

mutate

public List<CompletableFuture<Void>> mutate(List<? extends org.apache.hadoop.hbase.client.Mutation> arg0)

Specified by:

mutate in interface org.apache.hadoop.hbase.client.AsyncBufferedMutator

flush

public void flush()

Specified by:

flush in interface org.apache.hadoop.hbase.client.AsyncBufferedMutator

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hadoop.hbase.client.AsyncBufferedMutator

getWriteBufferSize

public long getWriteBufferSize()

Specified by:

getWriteBufferSize in interface org.apache.hadoop.hbase.client.AsyncBufferedMutator

getPeriodicalFlushTimeout

public long getPeriodicalFlushTimeout(TimeUnit arg0)

Specified by:

getPeriodicalFlushTimeout in interface org.apache.hadoop.hbase.client.AsyncBufferedMutator