Package 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	Description
private int	flushCount
(package private) org.apache.hbase.thirdparty.io.netty.util.Timeout	periodicFlushTask

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.hbase.TableName	getName()
long	getPeriodicalFlushTimeout(TimeUnit arg0)
Map<String,byte[]>	getRequestAttributes()
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 Details

flushCount

private int flushCount

periodicFlushTask

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

Constructor Details

AsyncBufferMutatorForTest

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

Method Details

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 org.apache.hadoop.hbase.client.AsyncBufferedMutator

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

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

getRequestAttributes

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

Specified by:

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