BufferedMutator
for batching mutations.@Deprecated @InterfaceAudience.Public public class HTableMultiplexer extends Object
Modifier and Type | Class and Description |
---|---|
static class |
HTableMultiplexer.HTableMultiplexerStatus
Deprecated.
since 2.2.0, will be removed in 3.0.0, without replacement. Please use
BufferedMutator for batching mutations. |
Modifier and Type | Field and Description |
---|---|
static String |
TABLE_MULTIPLEXER_FLUSH_PERIOD_MS
Deprecated.
|
static String |
TABLE_MULTIPLEXER_INIT_THREADS
Deprecated.
|
static String |
TABLE_MULTIPLEXER_MAX_RETRIES_IN_QUEUE
Deprecated.
|
Constructor and Description |
---|
HTableMultiplexer(org.apache.hadoop.conf.Configuration conf,
int perRegionServerBufferQueueSize)
Deprecated.
|
HTableMultiplexer(Connection conn,
org.apache.hadoop.conf.Configuration conf,
int perRegionServerBufferQueueSize)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Deprecated.
Closes the internal
Connection . |
HTableMultiplexer.HTableMultiplexerStatus |
getHTableMultiplexerStatus()
Deprecated.
|
List<Put> |
put(byte[] tableName,
List<Put> puts)
Deprecated.
Use
put(TableName, List) instead. |
boolean |
put(byte[] tableName,
Put put)
Deprecated.
Use
put(TableName, Put) instead. |
boolean |
put(byte[] tableName,
Put put,
int retry)
Deprecated.
Use
put(TableName, Put) instead. |
List<Put> |
put(TableName tableName,
List<Put> puts)
Deprecated.
The puts request will be buffered by their corresponding buffer queue.
|
boolean |
put(TableName tableName,
Put put)
Deprecated.
The put request will be buffered by its corresponding buffer queue.
|
boolean |
put(TableName tableName,
Put put,
int maxAttempts)
Deprecated.
The put request will be buffered by its corresponding buffer queue.
|
public static final String TABLE_MULTIPLEXER_FLUSH_PERIOD_MS
public static final String TABLE_MULTIPLEXER_INIT_THREADS
public static final String TABLE_MULTIPLEXER_MAX_RETRIES_IN_QUEUE
public HTableMultiplexer(org.apache.hadoop.conf.Configuration conf, int perRegionServerBufferQueueSize) throws IOException
conf
- The HBaseConfigurationperRegionServerBufferQueueSize
- determines the max number of the buffered Put ops for
each region server before dropping the request.IOException
public HTableMultiplexer(Connection conn, org.apache.hadoop.conf.Configuration conf, int perRegionServerBufferQueueSize)
conn
- The HBase connection.conf
- The HBase configurationperRegionServerBufferQueueSize
- determines the max number of the buffered Put ops for
each region server before dropping the request.public void close() throws IOException
Connection
. Does nothing if the Connection
has already
been closed.IOException
- If there is an error closing the connection.public boolean put(TableName tableName, Put put)
tableName
- put
- public List<Put> put(TableName tableName, List<Put> puts)
tableName
- puts
- @Deprecated public List<Put> put(byte[] tableName, List<Put> puts)
put(TableName, List)
instead.public boolean put(TableName tableName, Put put, int maxAttempts)
@Deprecated public boolean put(byte[] tableName, Put put, int retry)
put(TableName, Put)
instead.@Deprecated public boolean put(byte[] tableName, Put put)
put(TableName, Put)
instead.public HTableMultiplexer.HTableMultiplexerStatus getHTableMultiplexerStatus()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.