public class Mysql2HBaseDemo extends Object
| Modifier and Type | Class and Description |
|---|---|
class |
Mysql2HBaseDemo.DescMeta |
class |
Mysql2HBaseDemo.FlushTask |
| Modifier and Type | Field and Description |
|---|---|
static int |
BATCH_SIZE |
static String |
PRIMARY_INPUT_CONN |
static String |
PRIMARY_ROWKEY_CONN |
static int |
QUEUE_LENGTH |
static long |
SEND_INTERVAL |
static long |
SLEEP_INTERVAL |
static long |
SLEEP_SHORT_INTERVAL |
static long |
TIMER_DELAY |
static long |
TIMER_PERIOD |
| Constructor and Description |
|---|
Mysql2HBaseDemo(String strMyConf,
String strHbConf)
construct with string
|
| Modifier and Type | Method and Description |
|---|---|
void |
close()
close
|
static void |
main(String[] args)
args have 2 parameters
|
void |
run()
check the thread and driver's status
|
void |
start()
start main process
|
public static final long SLEEP_INTERVAL
public static final long SLEEP_SHORT_INTERVAL
public static final int QUEUE_LENGTH
public static final int BATCH_SIZE
public static final long SEND_INTERVAL
public static final long TIMER_DELAY
public static final long TIMER_PERIOD
public static final String PRIMARY_INPUT_CONN
public static final String PRIMARY_ROWKEY_CONN
Copyright © 2016. All rights reserved.