Serialized Form

Package org.apache.streams.mongo

Class org.apache.streams.mongo.MongoConfiguration extends Object implements Serializable

Serialized Fields

host

String host

Hbase host

port

Long port

ZK Port

user

String user

User

password

String password

Password

db

String db

DB

collection

String collection

Collection

Class org.apache.streams.mongo.MongoPersistReader extends Object implements Serializable

Serialized Fields

persistQueue

Queue<E> persistQueue

mapper

com.fasterxml.jackson.databind.ObjectMapper mapper

lastWrite

AtomicLong lastWrite

executor

ExecutorService executor

config

MongoConfiguration config

client

com.mongodb.MongoClient client

db

com.mongodb.DB db

collection

com.mongodb.DBCollection collection

cursor

com.mongodb.DBCursor cursor

lock

ReadWriteLock lock

Class org.apache.streams.mongo.MongoPersistWriter extends Object implements Serializable

Serialized Fields

persistQueue

Queue<E> persistQueue

mapper

com.fasterxml.jackson.databind.ObjectMapper mapper

lastWrite

AtomicLong lastWrite

backgroundFlushTask

ScheduledExecutorService backgroundFlushTask

config

MongoConfiguration config

client

com.mongodb.MongoClient client

db

com.mongodb.DB db

collection

com.mongodb.DBCollection collection

insertBatch

List<E> insertBatch

lock

ReadWriteLock lock