C D E F G H I L O P R S T W

C

cleanUp() - Method in class org.apache.streams.hbase.HbasePersistReader

cleanUp() - Method in class org.apache.streams.hbase.HbasePersistWriter

close() - Method in class org.apache.streams.hbase.HbasePersistWriter

config - Variable in class org.apache.streams.hbase.HbasePersistReader

connection - Variable in class org.apache.streams.hbase.HbasePersistWriter

constructQueue() - Method in class org.apache.streams.hbase.HbasePersistReader

D

descriptor - Variable in class org.apache.streams.hbase.HbasePersistWriter

E

equals(Object) - Method in class org.apache.streams.hbase.HbaseConfiguration

F

flush() - Method in class org.apache.streams.hbase.HbasePersistWriter

G

getAdditionalProperties() - Method in class org.apache.streams.hbase.HbaseConfiguration

getClientPort() - Method in class org.apache.streams.hbase.HbaseConfiguration

ZK Port

getFamily() - Method in class org.apache.streams.hbase.HbaseConfiguration

Column Family

getId() - Method in class org.apache.streams.hbase.HbasePersistReader

getId() - Method in class org.apache.streams.hbase.HbasePersistWriter

getParent() - Method in class org.apache.streams.hbase.HbaseConfiguration

WebHdfs port

getQualifier() - Method in class org.apache.streams.hbase.HbaseConfiguration

Qualifier

getQuorum() - Method in class org.apache.streams.hbase.HbaseConfiguration

User

getRootdir() - Method in class org.apache.streams.hbase.HbaseConfiguration

Hbase host

getRootserver() - Method in class org.apache.streams.hbase.HbaseConfiguration

Base path

getTable() - Method in class org.apache.streams.hbase.HbaseConfiguration

Table

H

hashCode() - Method in class org.apache.streams.hbase.HbaseConfiguration

HbaseConfiguration - Class in org.apache.streams.hbase

HbaseConfiguration() - Constructor for class org.apache.streams.hbase.HbaseConfiguration

HbasePersistReader - Class in org.apache.streams.hbase

HbasePersistReader() - Constructor for class org.apache.streams.hbase.HbasePersistReader

HbasePersistReader(HbaseConfiguration) - Constructor for class org.apache.streams.hbase.HbasePersistReader

HbasePersistReaderTask - Class in org.apache.streams.hbase

HbasePersistReaderTask(HbasePersistReader) - Constructor for class org.apache.streams.hbase.HbasePersistReaderTask

HbasePersistWriter - Class in org.apache.streams.hbase

HbasePersistWriter writes to hbase.

HbasePersistWriter() - Constructor for class org.apache.streams.hbase.HbasePersistWriter

HbasePersistWriter constructor - resolve HbaseConfiguration from JVM 'hbase'.

HbasePersistWriter(HbaseConfiguration) - Constructor for class org.apache.streams.hbase.HbasePersistWriter

HbasePersistWriter constructor - use supplied persistQueue.

HbasePersistWriterTask - Class in org.apache.streams.hbase

HbasePersistWriterTask writes to hbase on behalf of

HbasePersistWriterTask(HbasePersistWriter) - Constructor for class org.apache.streams.hbase.HbasePersistWriterTask

I

isRunning() - Method in class org.apache.streams.hbase.HbasePersistReader

L

lock - Variable in class org.apache.streams.hbase.HbasePersistReader

O

org.apache.streams.hbase - package org.apache.streams.hbase

P

persistQueue - Variable in class org.apache.streams.hbase.HbasePersistReader

persistQueue - Variable in class org.apache.streams.hbase.HbasePersistWriter

pool - Variable in class org.apache.streams.hbase.HbasePersistWriter

prepare(Object) - Method in class org.apache.streams.hbase.HbasePersistReader

prepare(Object) - Method in class org.apache.streams.hbase.HbasePersistWriter

props - Variable in class org.apache.streams.hbase.HbasePersistReader

R

readAll() - Method in class org.apache.streams.hbase.HbasePersistReader

readCurrent() - Method in class org.apache.streams.hbase.HbasePersistReader

readNew(BigInteger) - Method in class org.apache.streams.hbase.HbasePersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.hbase.HbasePersistReader

run() - Method in class org.apache.streams.hbase.HbasePersistReaderTask

run() - Method in class org.apache.streams.hbase.HbasePersistWriterTask

running - Variable in class org.apache.streams.hbase.HbasePersistReader

S

setAdditionalProperty(String, Object) - Method in class org.apache.streams.hbase.HbaseConfiguration

setClientPort(Long) - Method in class org.apache.streams.hbase.HbaseConfiguration

ZK Port

setConfig(HbaseConfiguration) - Method in class org.apache.streams.hbase.HbasePersistReader

setFamily(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

Column Family

setParent(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

WebHdfs port

setQualifier(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

Qualifier

setQuorum(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

User

setRootdir(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

Hbase host

setRootserver(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

Base path

setTable(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

Table

startStream() - Method in class org.apache.streams.hbase.HbasePersistReader

STREAMS_ID - Static variable in class org.apache.streams.hbase.HbasePersistReader

STREAMS_ID - Static variable in class org.apache.streams.hbase.HbasePersistWriter

T

table - Variable in class org.apache.streams.hbase.HbasePersistWriter

toString() - Method in class org.apache.streams.hbase.HbaseConfiguration

W

withAdditionalProperty(String, Object) - Method in class org.apache.streams.hbase.HbaseConfiguration

withClientPort(Long) - Method in class org.apache.streams.hbase.HbaseConfiguration

withFamily(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

withParent(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

withQualifier(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

withQuorum(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

withRootdir(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

withRootserver(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

withTable(String) - Method in class org.apache.streams.hbase.HbaseConfiguration

write(StreamsDatum) - Method in class org.apache.streams.hbase.HbasePersistReader

write(StreamsDatum) - Method in class org.apache.streams.hbase.HbasePersistWriter

C D E F G H I L O P R S T W