com.alicloud.tablestore.hbase

Class TablestoreBufferedMutator

java.lang.Object

com.alicloud.tablestore.hbase.TablestoreBufferedMutator

All Implemented Interfaces:

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

public class TablestoreBufferedMutator
extends Object
implements org.apache.hadoop.hbase.client.BufferedMutator

Nested Class Summary

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
TablestoreBufferedMutator(TablestoreConnection connection, org.apache.hadoop.hbase.TableName tableName)

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	getWriteBufferSize()
void	mutate(List<? extends org.apache.hadoop.hbase.client.Mutation> list)
void	mutate(org.apache.hadoop.hbase.client.Mutation mutation)
void	setClearBufferOnFail(boolean clearBufferOnFail)

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

Constructor Detail

TablestoreBufferedMutator

public TablestoreBufferedMutator(TablestoreConnection connection,
                                 org.apache.hadoop.hbase.TableName tableName)

Method Detail

getName

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

Specified by:

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

getConfiguration

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

Specified by:

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

mutate

public void mutate(org.apache.hadoop.hbase.client.Mutation mutation)
            throws IOException

Specified by:

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

Throws:

IOException

mutate

public void mutate(List<? extends org.apache.hadoop.hbase.client.Mutation> list)
            throws IOException

Specified by:

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

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

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

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

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

Throws:

IOException

getWriteBufferSize

public long getWriteBufferSize()

Specified by:

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

setClearBufferOnFail

public void setClearBufferOnFail(boolean clearBufferOnFail)