数据库模型图

- family : String

HBaseBizTaskRefStorage

- COMMIT_SERVER : ScheduledExecutorService - PUT_BUFFER : BlockingQueue<Row>

CommonLindormStorage

- DEFAULT_SERIALIZER : Serializer - family : String - rowKeyGenerator : RowKeyGenerator - semaphore : Semaphore

- tableService : TableService - isStarted : boolean - isInited : boolean # table : String

HBaseScheduleTaskStorage

Closeable

# close() : void

LindormBizTaskRefStorage

CommonHBaseStorage

CommonBufferingLindormStorage

+ init() : void + start(Map context) : void + stop() : void + close() : void

# doStart() : void # doStop() : void + run() : void # doCommit(long retires) : void

+ init() : void + start(Map context) : void + stop() : void + close() : void

- hTablePool : HTablePool - isStarted : boolean - isInited : boolean # table : String

LindormScheduleTaskStorage

# init() : void # start(Map context) : void # stop() : void

- DEFAULT_SERIALIZER : Serializer - rowKeyGenerator : RowKeyGenerator - semaphore : Semaphore

- COMMIT_SERVER : ScheduledExecutorService - PUT_BUFFER : BlockingQueue<Put>

LifeCycle

CommonBufferingHBaseStorage