JavaScript is disabled on your browser.
Skip navigation links
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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
Skip navigation links
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2017
The Apache Software Foundation
. All rights reserved.