Queue<E> persistQueue
com.fasterxml.jackson.databind.ObjectMapper mapper
ExecutorService executor
CompletableFuture<T> readerTaskFuture
CassandraConfiguration config
CassandraClient client
Iterator<E> rowIterator
ReadWriteLock lock
Queue<E> persistQueue
com.fasterxml.jackson.databind.ObjectMapper mapper
AtomicLong lastWrite
ScheduledExecutorService backgroundFlushTask
CassandraConfiguration config
CassandraClient client
com.datastax.driver.core.Session session
com.datastax.driver.core.PreparedStatement insertStatement
List<E> insertBatch
ReadWriteLock lock
Copyright © 2017 The Apache Software Foundation. All rights reserved.