io.kosong.crux.hbase — io.kosong.crux/crux-hbase 0.3.0

->curator clj

(->curator {:keys [zookeeper-quorum session-timeout connection-timeout
                   retry-base-sleep retry-max-count]})

->hbase-config clj

(->hbase-config {:keys [properties]})

->hbase-connection clj

(->hbase-connection {:keys [hbase-config]})

->kv-store clj

(->kv-store {:keys [hbase-connection namespace table family qualifier
                    create-table?]})

->tx-ingest-executor clj

(->tx-ingest-executor {:keys [index-store tx-log tx-ingester curator
                              mutex-path]})

ensure-namespace clj

(ensure-namespace conn ns)

ensure-table clj

(ensure-table conn ns table family)

HBaseKvIterator clj

HBaseKvSnapshot clj

HBaseKvStore clj

start-hbase-connection clj

(start-hbase-connection hbase-config)

TxIngestExecutor clj