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

A

addToBatch(DBObject) - Method in class org.apache.streams.mongo.MongoPersistWriter

C

cleanUp() - Method in class org.apache.streams.mongo.MongoPersistReader

cleanUp() - Method in class org.apache.streams.mongo.MongoPersistWriter

client - Variable in class org.apache.streams.mongo.MongoPersistReader

client - Variable in class org.apache.streams.mongo.MongoPersistWriter

close() - Method in class org.apache.streams.mongo.MongoPersistWriter

collection - Variable in class org.apache.streams.mongo.MongoPersistReader

collection - Variable in class org.apache.streams.mongo.MongoPersistWriter

cursor - Variable in class org.apache.streams.mongo.MongoPersistReader

D

db - Variable in class org.apache.streams.mongo.MongoPersistReader

db - Variable in class org.apache.streams.mongo.MongoPersistWriter

E

equals(Object) - Method in class org.apache.streams.mongo.MongoConfiguration

F

flush() - Method in class org.apache.streams.mongo.MongoPersistWriter

flushIfNecessary() - Method in class org.apache.streams.mongo.MongoPersistWriter

G

getCollection() - Method in class org.apache.streams.mongo.MongoConfiguration

Collection

getDb() - Method in class org.apache.streams.mongo.MongoConfiguration

DB

getHost() - Method in class org.apache.streams.mongo.MongoConfiguration

Hbase host

getId() - Method in class org.apache.streams.mongo.MongoPersistReader

getId() - Method in class org.apache.streams.mongo.MongoPersistWriter

getPassword() - Method in class org.apache.streams.mongo.MongoConfiguration

Password

getPersistQueue() - Method in class org.apache.streams.mongo.MongoPersistReader

getPersistQueue() - Method in class org.apache.streams.mongo.MongoPersistWriter

getPort() - Method in class org.apache.streams.mongo.MongoConfiguration

ZK Port

getUser() - Method in class org.apache.streams.mongo.MongoConfiguration

User

H

hashCode() - Method in class org.apache.streams.mongo.MongoConfiguration

I

insertBatch - Variable in class org.apache.streams.mongo.MongoPersistWriter

isRunning() - Method in class org.apache.streams.mongo.MongoPersistReader

L

lock - Variable in class org.apache.streams.mongo.MongoPersistReader

lock - Variable in class org.apache.streams.mongo.MongoPersistWriter

M

MongoConfiguration - Class in org.apache.streams.mongo

MongoConfiguration() - Constructor for class org.apache.streams.mongo.MongoConfiguration

MongoPersistReader - Class in org.apache.streams.mongo

MongoPersistReader reads documents from mongo.

MongoPersistReader() - Constructor for class org.apache.streams.mongo.MongoPersistReader

KafkaPersistReader constructor - resolves KafkaConfiguration from JVM 'mongo'.

MongoPersistReader(MongoConfiguration) - Constructor for class org.apache.streams.mongo.MongoPersistReader

KafkaPersistReader constructor - uses supplied MongoConfiguration.

MongoPersistReader(Queue<StreamsDatum>) - Constructor for class org.apache.streams.mongo.MongoPersistReader

KafkaPersistReader constructor - uses supplied persistQueue.

MongoPersistReader.MongoPersistReaderTask - Class in org.apache.streams.mongo

MongoPersistReaderTask(MongoPersistReader) - Constructor for class org.apache.streams.mongo.MongoPersistReader.MongoPersistReaderTask

MongoPersistWriter - Class in org.apache.streams.mongo

MongoPersistWriter() - Constructor for class org.apache.streams.mongo.MongoPersistWriter

MongoPersistWriter(MongoConfiguration) - Constructor for class org.apache.streams.mongo.MongoPersistWriter

O

org.apache.streams.mongo - package org.apache.streams.mongo

P

persistQueue - Variable in class org.apache.streams.mongo.MongoPersistReader

persistQueue - Variable in class org.apache.streams.mongo.MongoPersistWriter

prepare(Object) - Method in class org.apache.streams.mongo.MongoPersistReader

prepare(Object) - Method in class org.apache.streams.mongo.MongoPersistWriter

prepareDatum(DBObject) - Method in class org.apache.streams.mongo.MongoPersistReader

prepareObject(StreamsDatum) - Method in class org.apache.streams.mongo.MongoPersistWriter

R

readAll() - Method in class org.apache.streams.mongo.MongoPersistReader

readCurrent() - Method in class org.apache.streams.mongo.MongoPersistReader

readNew(BigInteger) - Method in class org.apache.streams.mongo.MongoPersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.mongo.MongoPersistReader

run() - Method in class org.apache.streams.mongo.MongoPersistReader.MongoPersistReaderTask

run() - Method in class org.apache.streams.mongo.MongoPersistWriter

S

setCollection(String) - Method in class org.apache.streams.mongo.MongoConfiguration

Collection

setDb(String) - Method in class org.apache.streams.mongo.MongoConfiguration

DB

setHost(String) - Method in class org.apache.streams.mongo.MongoConfiguration

Hbase host

setPassword(String) - Method in class org.apache.streams.mongo.MongoConfiguration

Password

setPersistQueue(Queue<StreamsDatum>) - Method in class org.apache.streams.mongo.MongoPersistReader

setPersistQueue(Queue<StreamsDatum>) - Method in class org.apache.streams.mongo.MongoPersistWriter

setPort(Long) - Method in class org.apache.streams.mongo.MongoConfiguration

ZK Port

setUser(String) - Method in class org.apache.streams.mongo.MongoConfiguration

User

start() - Method in class org.apache.streams.mongo.MongoPersistWriter

start write thread.

startStream() - Method in class org.apache.streams.mongo.MongoPersistReader

stop() - Method in class org.apache.streams.mongo.MongoPersistReader

stop() - Method in class org.apache.streams.mongo.MongoPersistWriter

stop.

STREAMS_ID - Static variable in class org.apache.streams.mongo.MongoPersistReader

STREAMS_ID - Static variable in class org.apache.streams.mongo.MongoPersistWriter

T

toString() - Method in class org.apache.streams.mongo.MongoConfiguration

W

withCollection(String) - Method in class org.apache.streams.mongo.MongoConfiguration

withDb(String) - Method in class org.apache.streams.mongo.MongoConfiguration

withHost(String) - Method in class org.apache.streams.mongo.MongoConfiguration

withPassword(String) - Method in class org.apache.streams.mongo.MongoConfiguration

withPort(Long) - Method in class org.apache.streams.mongo.MongoConfiguration

withUser(String) - Method in class org.apache.streams.mongo.MongoConfiguration

write(StreamsDatum) - Method in class org.apache.streams.mongo.MongoPersistReader

write(StreamsDatum) - Method in class org.apache.streams.mongo.MongoPersistWriter

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