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