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 TypeMethodDescriptionvoid
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) 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
- Throws:
SQLException
-
deleteAllRows
- Throws:
SQLException
-
upsertEntry
void upsertEntry(Connection connection, int segment, MarshallableEntry<? extends K, ? extends V> entry) throws SQLException- Throws:
SQLException
-
size
- 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
-