- 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
