Serialized Form

Package org.apache.streams.hbase

Class org.apache.streams.hbase.HbaseConfiguration extends Object implements Serializable

Serialized Fields

rootdir

String rootdir

Hbase host

parent

String parent

WebHdfs port

rootserver

String rootserver

Base path

quorum

String quorum

User

clientPort

Long clientPort

ZK Port

table

String table

Table

family

String family

Column Family

qualifier

String qualifier

Qualifier

additionalProperties

Map<K,V> additionalProperties

Class org.apache.streams.hbase.HbasePersistReader extends Object implements Serializable

Serialized Fields

lock

ReadWriteLock lock

running

AtomicBoolean running

persistQueue

Queue<E> persistQueue

mapper

com.fasterxml.jackson.databind.ObjectMapper mapper

config

HbaseConfiguration config

props

Properties props

executor

ExecutorService executor

task

HbasePersistReaderTask task

Class org.apache.streams.hbase.HbasePersistWriter extends Object implements Serializable

Serialized Fields

connection

org.apache.hadoop.hbase.client.HConnection connection

pool

org.apache.hadoop.hbase.client.HTablePool pool

table

org.apache.hadoop.hbase.client.HTableInterface table

descriptor

org.apache.hadoop.hbase.HTableDescriptor descriptor

persistQueue

Queue<E> persistQueue

mapper

com.fasterxml.jackson.databind.ObjectMapper mapper

config

HbaseConfiguration config