JavaScript is disabled on your browser.
Skip navigation links
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
C
E
F
G
H
I
L
O
P
R
S
T
W
C
CassandraClient
- Class in
org.apache.streams.cassandra
CassandraClient(CassandraConfiguration)
- Constructor for class org.apache.streams.cassandra.
CassandraClient
CassandraConfiguration
- Class in
org.apache.streams.cassandra
CassandraConfiguration()
- Constructor for class org.apache.streams.cassandra.
CassandraConfiguration
CassandraPersistReader
- Class in
org.apache.streams.cassandra
CassandraPersistReader reads documents from cassandra.
CassandraPersistReader()
- Constructor for class org.apache.streams.cassandra.
CassandraPersistReader
CassandraPersistReader constructor
CassandraPersistReader(CassandraConfiguration)
- Constructor for class org.apache.streams.cassandra.
CassandraPersistReader
CassandraPersistReader constructor - uses supplied CassandraConfiguration.
CassandraPersistReader(Queue<StreamsDatum>)
- Constructor for class org.apache.streams.cassandra.
CassandraPersistReader
CassandraPersistReader constructor - uses supplied persistQueue.
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
E
equals(Object)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
equals(Object)
- Method in class org.apache.streams.cassandra.
Ssl
F
flush()
- Method in class org.apache.streams.cassandra.
CassandraPersistWriter
flushIfNecessary()
- Method in class org.apache.streams.cassandra.
CassandraPersistWriter
G
getAdditionalProperties()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
getAdditionalProperties()
- Method in class org.apache.streams.cassandra.
Ssl
getColumn()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Column name
getEnabled()
- Method in class org.apache.streams.cassandra.
Ssl
ssl enabled
getHosts()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Cassandra hosts
getId()
- Method in class org.apache.streams.cassandra.
CassandraPersistReader
getId()
- Method in class org.apache.streams.cassandra.
CassandraPersistWriter
getKeyspace()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Keyspace
getKeyStore()
- Method in class org.apache.streams.cassandra.
Ssl
getKeyStorePassword()
- Method in class org.apache.streams.cassandra.
Ssl
getPartitionKeyColumn()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Partition Key column name
getPassword()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Password
getPersistQueue()
- Method in class org.apache.streams.cassandra.
CassandraPersistReader
getPersistQueue()
- Method in class org.apache.streams.cassandra.
CassandraPersistWriter
getPort()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Cassandra port
getSsl()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
ssl details
getTable()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Table
getTrustStore()
- Method in class org.apache.streams.cassandra.
Ssl
getTrustStorePassword()
- Method in class org.apache.streams.cassandra.
Ssl
getUser()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
User
H
hashCode()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
hashCode()
- Method in class org.apache.streams.cassandra.
Ssl
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
setAdditionalProperty(String, Object)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
setAdditionalProperty(String, Object)
- Method in class org.apache.streams.cassandra.
Ssl
setColumn(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Column name
setEnabled(Boolean)
- Method in class org.apache.streams.cassandra.
Ssl
ssl enabled
setHosts(List<String>)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Cassandra hosts
setKeyspace(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Keyspace
setKeyStore(String)
- Method in class org.apache.streams.cassandra.
Ssl
setKeyStorePassword(String)
- Method in class org.apache.streams.cassandra.
Ssl
setPartitionKeyColumn(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Partition Key column name
setPassword(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Password
setPersistQueue(Queue<StreamsDatum>)
- Method in class org.apache.streams.cassandra.
CassandraPersistReader
setPersistQueue(Queue<StreamsDatum>)
- Method in class org.apache.streams.cassandra.
CassandraPersistWriter
setPort(Long)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Cassandra port
setSsl(Ssl)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
ssl details
setTable(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
Table
setTrustStore(String)
- Method in class org.apache.streams.cassandra.
Ssl
setTrustStorePassword(String)
- Method in class org.apache.streams.cassandra.
Ssl
setUser(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
User
Ssl
- Class in
org.apache.streams.cassandra
ssl details
Ssl()
- Constructor for class org.apache.streams.cassandra.
Ssl
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
T
toString()
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
toString()
- Method in class org.apache.streams.cassandra.
Ssl
W
withAdditionalProperty(String, Object)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
withAdditionalProperty(String, Object)
- Method in class org.apache.streams.cassandra.
Ssl
withColumn(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
withEnabled(Boolean)
- Method in class org.apache.streams.cassandra.
Ssl
withHosts(List<String>)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
withKeyspace(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
withKeyStore(String)
- Method in class org.apache.streams.cassandra.
Ssl
withKeyStorePassword(String)
- Method in class org.apache.streams.cassandra.
Ssl
withPartitionKeyColumn(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
withPassword(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
withPort(Long)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
withSsl(Ssl)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
withTable(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
withTrustStore(String)
- Method in class org.apache.streams.cassandra.
Ssl
withTrustStorePassword(String)
- Method in class org.apache.streams.cassandra.
Ssl
withUser(String)
- Method in class org.apache.streams.cassandra.
CassandraConfiguration
write(StreamsDatum)
- Method in class org.apache.streams.cassandra.
CassandraPersistReader
write(StreamsDatum)
- Method in class org.apache.streams.cassandra.
CassandraPersistWriter
C
E
F
G
H
I
L
O
P
R
S
T
W
Skip navigation links
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2018
The Apache Software Foundation
. All rights reserved.