Index (kafka-streams-cassandra-state-store 0.8.3 API)

A B C D E F G H I N O P Q R S T V W
All Classes and Interfaces|All Packages

A

AbstractCassandraStateStoreRepository<K> - Class in dev.thriving.oss.kafka.streams.cassandra.state.store.repo
AbstractCassandraStateStoreRepository(CqlSession, String, boolean, String, String, String) - Constructor for class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.AbstractCassandraStateStoreRepository
AbstractCassandraStore - Class in dev.thriving.oss.kafka.streams.cassandra.state.store
AbstractCassandraStore(String) - Constructor for class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore
all() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore
approximateNumEntries() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore

B

buildCreateTableQuery(String, String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.AbstractCassandraStateStoreRepository
buildCreateTableQuery(String, String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
buildCreateTableQuery(String, String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraVersionedKeyValueStoreRepository
buildCreateTableQuery(String, String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
buildCreateTableQuery(String, String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraVersionedKeyValueStoreRepository
builder(CqlSession, String) - Static method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: Create a builder with cassandra @CqlSession and store name provided as mandatory parameters.

C

CassandraKeyValueIterator - Class in dev.thriving.oss.kafka.streams.cassandra.state.store: Implements KeyValueIterator wrapping cassandra java client query ResultSet iterator -> Iterator<com.datastax.oss.driver.api.core.cql.Row>.
CassandraKeyValueIterator(Iterator<Row>) - Constructor for class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueIterator: Constructor for wrapping a cassandra java client query ResultSet iterator Iterator<com.datastax.oss.driver.api.core.cql.Row>.
CassandraKeyValueStore - Class in dev.thriving.oss.kafka.streams.cassandra.state.store
CassandraKeyValueStore(String, CassandraKeyValueStoreRepository, boolean) - Constructor for class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore
CassandraKeyValueStoreRepository - Interface in dev.thriving.oss.kafka.streams.cassandra.state.store.repo
CassandraStateStore - Interface in dev.thriving.oss.kafka.streams.cassandra.state.store: Implemented by all the libraries custom StateStore solutions.
CassandraStores - Class in dev.thriving.oss.kafka.streams.cassandra.state.store: Factory for creating cassandra backed state stores in Kafka Streams.
CassandraVersionedKeyValueStore - Class in dev.thriving.oss.kafka.streams.cassandra.state.store
CassandraVersionedKeyValueStore(String, CassandraVersionedKeyValueStoreRepository, long) - Constructor for class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraVersionedKeyValueStore
CassandraVersionedKeyValueStoreRepository - Interface in dev.thriving.oss.kafka.streams.cassandra.state.store.repo
cleanup(int, Bytes, Instant) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraVersionedKeyValueStoreRepository
cleanup(int, Bytes, Instant) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraVersionedKeyValueStoreRepository
cleanup(int, Bytes, Instant) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraVersionedKeyValueStoreRepository
close() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore
close() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueIterator
close() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.utils.CompositeKeyValueIterator
CompositeKeyValueIterator<K,V> - Class in dev.thriving.oss.kafka.streams.cassandra.state.store.utils
CompositeKeyValueIterator(Iterator<KeyValueIterator<Bytes, byte[]>>, Deserializer<K>, Deserializer<V>) - Constructor for class dev.thriving.oss.kafka.streams.cassandra.state.store.utils.CompositeKeyValueIterator
context - Variable in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore

D

ddlExecutionProfile - Variable in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.AbstractCassandraStateStoreRepository
DEFAULT_TABLE_NAME_FN - Static variable in interface dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStateStore
delete(int, Bytes) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraKeyValueStoreRepository
delete(int, Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
delete(int, Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
delete(Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore
delete(Bytes, long) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraVersionedKeyValueStore
dev.thriving.oss.kafka.streams.cassandra.state.store - package dev.thriving.oss.kafka.streams.cassandra.state.store
dev.thriving.oss.kafka.streams.cassandra.state.store.repo - package dev.thriving.oss.kafka.streams.cassandra.state.store.repo
dev.thriving.oss.kafka.streams.cassandra.state.store.utils - package dev.thriving.oss.kafka.streams.cassandra.state.store.utils
dmlExecutionProfile - Variable in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.AbstractCassandraStateStoreRepository

E

emptyIterator() - Static method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueIterator
equals(Object) - Method in record class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.VersionedEntry: Indicates whether some other object is "equal to" this one.
executeSelectCount(BoundStatement) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.AbstractCassandraStateStoreRepository

F

flush() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore

G

get(int, Bytes) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraVersionedKeyValueStoreRepository
get(int, Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraVersionedKeyValueStoreRepository
get(int, Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraVersionedKeyValueStoreRepository
get(int, Bytes, Instant) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraVersionedKeyValueStoreRepository
get(int, Bytes, Instant) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraVersionedKeyValueStoreRepository
get(int, Bytes, Instant) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraVersionedKeyValueStoreRepository
get(Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore
get(Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraVersionedKeyValueStore
get(Bytes, long) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraVersionedKeyValueStore
getAll(int, boolean) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraKeyValueStoreRepository
getAll(int, boolean) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
getAll(int, boolean) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
getByKey(int, Bytes) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraKeyValueStoreRepository
getByKey(int, Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
getByKey(int, Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
getCount() - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraKeyValueStoreRepository
getCount() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
getCount() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
getCount(int) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraKeyValueStoreRepository
getCount(int) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
getCount(int) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
getForRange(int, Bytes, Bytes, boolean, boolean) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraKeyValueStoreRepository
getForRange(int, Bytes, Bytes, boolean, boolean) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
getForRange(int, Bytes, Bytes, boolean, boolean) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
getPosition() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore
GlobalCassandraKeyValueStoreRepository - Class in dev.thriving.oss.kafka.streams.cassandra.state.store.repo
GlobalCassandraKeyValueStoreRepository(CqlSession, String, boolean, String, String, String) - Constructor for class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
GlobalCassandraVersionedKeyValueStoreRepository<K> - Class in dev.thriving.oss.kafka.streams.cassandra.state.store.repo
GlobalCassandraVersionedKeyValueStoreRepository(CqlSession, String, boolean, String, String, String) - Constructor for class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraVersionedKeyValueStoreRepository
globalKeyValueStore() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: Creates a persistent KeyValueBytesStoreSupplier.
globalVersionedKeyValueStore(Duration) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: Creates a persistent VersionedBytesStoreSupplier.

H

hashCode() - Method in record class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.VersionedEntry: Returns a hash code value for this object.
hasNext() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueIterator
hasNext() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.utils.CompositeKeyValueIterator

I

init(ProcessorContext, StateStore) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore: Deprecated.
init(StateStoreContext, StateStore) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore
initPreparedStatements(String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.AbstractCassandraStateStoreRepository
initPreparedStatements(String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
initPreparedStatements(String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraVersionedKeyValueStoreRepository
initPreparedStatements(String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
initPreparedStatements(String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraVersionedKeyValueStoreRepository
isOpen() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore

N

name - Variable in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore
name() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore
next() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueIterator
next() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.utils.CompositeKeyValueIterator

O

open - Variable in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore

P

partition - Variable in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore
PartitionedCassandraKeyValueStoreRepository<K> - Class in dev.thriving.oss.kafka.streams.cassandra.state.store.repo
PartitionedCassandraKeyValueStoreRepository(CqlSession, String, boolean, String, String, String) - Constructor for class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
PartitionedCassandraVersionedKeyValueStoreRepository<K> - Class in dev.thriving.oss.kafka.streams.cassandra.state.store.repo
PartitionedCassandraVersionedKeyValueStoreRepository(CqlSession, String, boolean, String, String, String) - Constructor for class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraVersionedKeyValueStoreRepository
partitionedKeyValueStore() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: Creates a persistent KeyValueBytesStoreSupplier.
partitionedVersionedKeyValueStore(Duration) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: Creates a persistent VersionedBytesStoreSupplier.
peekNextKey() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueIterator
peekNextKey() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.utils.CompositeKeyValueIterator
persistent() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore
position - Variable in class dev.thriving.oss.kafka.streams.cassandra.state.store.AbstractCassandraStore
prefixScan(P, PS) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore
put(Bytes, byte[]) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore
put(Bytes, byte[], long) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraVersionedKeyValueStore
putAll(List<KeyValue<Bytes, byte[]>>) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore
putIfAbsent(Bytes, byte[]) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore

Q

query(Query<R>, PositionBound, QueryConfig) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore

R

range(Bytes, Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore
readOnlyGlobalKeyValueStore(KafkaStreams, String) - Static method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStateStore: Get a facade wrapping the local CassandraStateStore.
readOnlyPartitionedKeyValueStore(KafkaStreams, String, CqlSession, String, boolean, String, Serde<K>, Serde<V>) - Static method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStateStore: Get an optimised special implementation of ReadOnlyKeyValueStore for 'partitioned' type CassandraKeyValueStore.
readOnlyPartitionedKeyValueStore(KafkaStreams, String, CqlSession, String, boolean, String, Serde<K>, Serde<V>, Function<String, String>, StreamPartitioner<K, V>) - Static method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStateStore: Get an optimised special implementation of ReadOnlyKeyValueStore for 'partitioned' type CassandraKeyValueStore.
reverseAll() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore
reverseRange(Bytes, Bytes) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraKeyValueStore

S

save(int, Bytes, byte[]) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraKeyValueStoreRepository
save(int, Bytes, byte[]) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
save(int, Bytes, byte[]) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
saveBatch(int, List<KeyValue<Bytes, byte[]>>) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraKeyValueStoreRepository
saveBatch(int, List<KeyValue<Bytes, byte[]>>) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraKeyValueStoreRepository
saveBatch(int, List<KeyValue<Bytes, byte[]>>) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraKeyValueStoreRepository
saveInBatch(int, Bytes, List<VersionedEntry>) - Method in interface dev.thriving.oss.kafka.streams.cassandra.state.store.repo.CassandraVersionedKeyValueStoreRepository
saveInBatch(int, Bytes, List<VersionedEntry>) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.GlobalCassandraVersionedKeyValueStoreRepository
saveInBatch(int, Bytes, List<VersionedEntry>) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.PartitionedCassandraVersionedKeyValueStoreRepository
session - Variable in class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.AbstractCassandraStateStoreRepository

T

timestamp() - Method in record class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.VersionedEntry: Returns the value of the timestamp record component.
toString() - Method in record class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.VersionedEntry: Returns a string representation of this record class.

V

validFrom() - Method in record class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.VersionedEntry: Returns the value of the validFrom record component.
validTo() - Method in record class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.VersionedEntry: Returns the value of the validTo record component.
value() - Method in record class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.VersionedEntry: Returns the value of the value record component.
VersionedEntry - Record Class in dev.thriving.oss.kafka.streams.cassandra.state.store.repo
VersionedEntry(byte[], Instant, Instant, Instant) - Constructor for record class dev.thriving.oss.kafka.streams.cassandra.state.store.repo.VersionedEntry: Creates an instance of a VersionedEntry record class.

W

withCountAllEnabled() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: Enable (opt-in) the CassandraKeyValueStore to use `SELECT COUNT(*)` when approximateNumEntries is invoked.
withCreateTableDisabled() - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: Disable (opt-out) automatic table creation during store initialization.
withDdlExecutionProfile(String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: Set the execution profile to be used by the driver for all DDL (Data Definition Language) queries.
withDmlExecutionProfile(String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: Set the execution profile to be used by the driver for all DML (Data Manipulation Language) queries.
withKeyspace(String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: The keyspace for the state store to operate in.
withTableNameFn(Function<String, String>) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: Customize how the state store cassandra table is named, based on the kstreams store name.
withTableOptions(String) - Method in class dev.thriving.oss.kafka.streams.cassandra.state.store.CassandraStores: A CQL table has a number of options that can be set at creation.

A B C D E F G H I N O P Q R S T V W
All Classes and Interfaces|All Packages