Interface TableOperations<K,V>

All Known Implementing Classes:

AbstractSchemaJdbcStore.SchemaTableOperations, BaseTableOperations, QueriesJdbcStore.QueryTableOperations, TableJdbcStore.TableTableOperations

public interface TableOperations<K,V>

Author:

William Burns

Method Summary

Modifier and Type	Method	Description
void	batchUpdates(Connection connection, int writePublisherCount, org.reactivestreams.Publisher<Object> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
void	deleteAllRows(Connection connection)
boolean	deleteEntry(Connection connection, int segment, Object key)
MarshallableEntry<K,V>	loadEntry(Connection connection, int segment, Object key)
io.reactivex.rxjava3.core.Flowable<MarshallableEntry<K,V>>	publishEntries(Supplier<Connection> connectionSupplier, Consumer<Connection> connectionCloser, IntSet segments, Predicate<? super K> filter, boolean fetchValue)
default io.reactivex.rxjava3.core.Flowable<K>	publishKeys(Supplier<Connection> connectionSupplier, Consumer<Connection> connectionCloser, IntSet segments, Predicate<? super K> filter)
long	size(Connection connection)
void	upsertEntry(Connection connection, int segment, MarshallableEntry<? extends K, ? extends V> entry)

Method Details

loadEntry

MarshallableEntry<K,V> loadEntry(Connection connection,
 int segment,
 Object key)
                          throws SQLException

Throws:

SQLException

publishKeys

default io.reactivex.rxjava3.core.Flowable<K> publishKeys(Supplier<Connection> connectionSupplier,
 Consumer<Connection> connectionCloser,
 IntSet segments,
 Predicate<? super K> filter)

publishEntries

io.reactivex.rxjava3.core.Flowable<MarshallableEntry<K,V>> publishEntries(Supplier<Connection> connectionSupplier,
 Consumer<Connection> connectionCloser,
 IntSet segments,
 Predicate<? super K> filter,
 boolean fetchValue)

deleteEntry

boolean deleteEntry(Connection connection,
 int segment,
 Object key)
             throws SQLException

Throws:

SQLException

deleteAllRows

void deleteAllRows(Connection connection)
            throws SQLException

Throws:

SQLException

upsertEntry

void upsertEntry(Connection connection,
 int segment,
 MarshallableEntry<? extends K, ? extends V> entry)
          throws SQLException

Throws:

SQLException

size

long size(Connection connection)
   throws SQLException

Throws:

SQLException

batchUpdates

void batchUpdates(Connection connection,
 int writePublisherCount,
 org.reactivestreams.Publisher<Object> removePublisher,
 org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
           throws SQLException

Throws:

SQLException