Serialized Form

Package org.apache.streams.cassandra

Class org.apache.streams.cassandra.CassandraConfiguration extends Object implements Serializable

Serialized Fields

hosts

List<E> hosts

Cassandra hosts

port

Long port

Cassandra port

user

String user

User

password

String password

Password

keyspace

String keyspace

Keyspace

table

String table

Table

partitionKeyColumn

String partitionKeyColumn

Partition Key column name

column

String column

Column name

ssl

Ssl ssl

ssl details

additionalProperties

Map<K,V> additionalProperties

Class org.apache.streams.cassandra.CassandraPersistReader extends Object implements Serializable

Serialized Fields

persistQueue

Queue<E> persistQueue

mapper

com.fasterxml.jackson.databind.ObjectMapper mapper

executor

ExecutorService executor

readerTaskFuture

CompletableFuture<T> readerTaskFuture

config

CassandraConfiguration config

client

CassandraClient client

rowIterator

Iterator<E> rowIterator

lock

ReadWriteLock lock

Class org.apache.streams.cassandra.CassandraPersistWriter extends Object implements Serializable

Serialized Fields

persistQueue

Queue<E> persistQueue

mapper

com.fasterxml.jackson.databind.ObjectMapper mapper

lastWrite

AtomicLong lastWrite

backgroundFlushTask

ScheduledExecutorService backgroundFlushTask

config

CassandraConfiguration config

client

CassandraClient client

session

com.datastax.driver.core.Session session

insertStatement

com.datastax.driver.core.PreparedStatement insertStatement

insertBatch

List<E> insertBatch

lock

ReadWriteLock lock

Class org.apache.streams.cassandra.Ssl extends Object implements Serializable

Serialized Fields

enabled

Boolean enabled

ssl enabled

trustStore

String trustStore

trustStorePassword

String trustStorePassword

keyStore

String keyStore

keyStorePassword

String keyStorePassword

additionalProperties

Map<K,V> additionalProperties