protected class MultiThreadedUpdater.HBaseUpdaterThread extends Thread
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.hbase.client.Table |
table |
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
HBaseUpdaterThread(int updaterId) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeHTable() |
protected org.apache.hadoop.hbase.client.Table |
createTable() |
protected org.apache.hadoop.hbase.client.Result |
getRow(org.apache.hadoop.hbase.client.Get get,
long rowKeyBase,
byte[] cf) |
void |
mutate(org.apache.hadoop.hbase.client.Table table,
org.apache.hadoop.hbase.client.Mutation m,
long keyBase) |
void |
mutate(org.apache.hadoop.hbase.client.Table table,
org.apache.hadoop.hbase.client.Mutation m,
long keyBase,
byte[] row,
byte[] cf,
byte[] q,
byte[] v) |
void |
run() |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
protected final org.apache.hadoop.hbase.client.Table table
public HBaseUpdaterThread(int updaterId) throws IOException
IOException
protected org.apache.hadoop.hbase.client.Table createTable() throws IOException
IOException
protected void closeHTable()
protected org.apache.hadoop.hbase.client.Result getRow(org.apache.hadoop.hbase.client.Get get, long rowKeyBase, byte[] cf)
public void mutate(org.apache.hadoop.hbase.client.Table table, org.apache.hadoop.hbase.client.Mutation m, long keyBase)
public void mutate(org.apache.hadoop.hbase.client.Table table, org.apache.hadoop.hbase.client.Mutation m, long keyBase, byte[] row, byte[] cf, byte[] q, byte[] v)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.