C F G I L O P R S W

C

CassandraClient - Class in org.apache.streams.cassandra

CassandraClient(CassandraConfiguration) - Constructor for class org.apache.streams.cassandra.CassandraClient

CassandraPersistReader - Class in org.apache.streams.cassandra

CassandraPersistReader reads documents from cassandra.

CassandraPersistReader() - Constructor for class org.apache.streams.cassandra.CassandraPersistReader

CassandraPersistReader constructor - resolves CassandraConfiguration from JVM 'cassandra'.

CassandraPersistReader(CassandraConfiguration) - Constructor for class org.apache.streams.cassandra.CassandraPersistReader

CassandraPersistReader constructor - uses supplied CassandraConfiguration.

CassandraPersistReader.CassandraPersistReaderTask - Class in org.apache.streams.cassandra

CassandraPersistReaderTask(CassandraPersistReader) - Constructor for class org.apache.streams.cassandra.CassandraPersistReader.CassandraPersistReaderTask

CassandraPersistWriter - Class in org.apache.streams.cassandra

CassandraPersistWriter() - Constructor for class org.apache.streams.cassandra.CassandraPersistWriter

CassandraPersistWriter(CassandraConfiguration) - Constructor for class org.apache.streams.cassandra.CassandraPersistWriter

cleanUp() - Method in class org.apache.streams.cassandra.CassandraPersistReader

cleanUp() - Method in class org.apache.streams.cassandra.CassandraPersistWriter

client() - Method in class org.apache.streams.cassandra.CassandraClient

close() - Method in class org.apache.streams.cassandra.CassandraPersistWriter

cluster() - Method in class org.apache.streams.cassandra.CassandraClient

config - Variable in class org.apache.streams.cassandra.CassandraClient

config() - Method in class org.apache.streams.cassandra.CassandraClient

F

flush() - Method in class org.apache.streams.cassandra.CassandraPersistWriter

flushIfNecessary() - Method in class org.apache.streams.cassandra.CassandraPersistWriter

G

getId() - Method in class org.apache.streams.cassandra.CassandraPersistReader

getId() - Method in class org.apache.streams.cassandra.CassandraPersistWriter

getPersistQueue() - Method in class org.apache.streams.cassandra.CassandraPersistReader

getPersistQueue() - Method in class org.apache.streams.cassandra.CassandraPersistWriter

I

insertBatch - Variable in class org.apache.streams.cassandra.CassandraPersistWriter

insertStatement - Variable in class org.apache.streams.cassandra.CassandraPersistWriter

isRunning() - Method in class org.apache.streams.cassandra.CassandraPersistReader

L

lock - Variable in class org.apache.streams.cassandra.CassandraPersistReader

lock - Variable in class org.apache.streams.cassandra.CassandraPersistWriter

LOGGER - Static variable in class org.apache.streams.cassandra.CassandraPersistReader

O

org.apache.streams.cassandra - package org.apache.streams.cassandra

P

persistQueue - Variable in class org.apache.streams.cassandra.CassandraPersistReader

persistQueue - Variable in class org.apache.streams.cassandra.CassandraPersistWriter

prepare(Object) - Method in class org.apache.streams.cassandra.CassandraPersistReader

prepare(Object) - Method in class org.apache.streams.cassandra.CassandraPersistWriter

prepareDatum(Row) - Method in class org.apache.streams.cassandra.CassandraPersistReader

R

readAll() - Method in class org.apache.streams.cassandra.CassandraPersistReader

readCurrent() - Method in class org.apache.streams.cassandra.CassandraPersistReader

readNew(BigInteger) - Method in class org.apache.streams.cassandra.CassandraPersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.cassandra.CassandraPersistReader

rowIterator - Variable in class org.apache.streams.cassandra.CassandraPersistReader

run() - Method in class org.apache.streams.cassandra.CassandraPersistReader.CassandraPersistReaderTask

run() - Method in class org.apache.streams.cassandra.CassandraPersistWriter

S

setPersistQueue(Queue<StreamsDatum>) - Method in class org.apache.streams.cassandra.CassandraPersistReader

setPersistQueue(Queue<StreamsDatum>) - Method in class org.apache.streams.cassandra.CassandraPersistWriter

start() - Method in class org.apache.streams.cassandra.CassandraClient

start() - Method in class org.apache.streams.cassandra.CassandraPersistWriter

start write thread.

startStream() - Method in class org.apache.streams.cassandra.CassandraPersistReader

stop() - Method in class org.apache.streams.cassandra.CassandraClient

stop() - Method in class org.apache.streams.cassandra.CassandraPersistReader

stop() - Method in class org.apache.streams.cassandra.CassandraPersistWriter

stop.

STREAMS_ID - Static variable in class org.apache.streams.cassandra.CassandraPersistReader

STREAMS_ID - Static variable in class org.apache.streams.cassandra.CassandraPersistWriter

W

write(StreamsDatum) - Method in class org.apache.streams.cassandra.CassandraPersistReader

write(StreamsDatum) - Method in class org.apache.streams.cassandra.CassandraPersistWriter

C F G I L O P R S W