public interface AsyncDatasetWriterReader<K extends java.lang.Comparable<K>> extends AsyncDatasetReader<K>
DatasetWriterReader
.Modifier and Type | Method and Description |
---|---|
default Operation<java.lang.Boolean> |
add(K key,
Cell<?>... cells)
An asynchronous equivalent to
DatasetWriterReader.add(Comparable, Cell...) . |
Operation<java.lang.Boolean> |
add(K key,
java.lang.Iterable<Cell<?>> cells)
An asynchronous equivalent to
DatasetWriterReader.add(Comparable, Iterable) . |
Operation<java.lang.Boolean> |
delete(K key)
An asynchronous equivalent to
DatasetWriterReader.delete(Comparable) . |
AsyncReadWriteRecordAccessor<K> |
on(K key)
Equivalent to
DatasetWriterReader.on(Comparable) , but returns an AsyncReadWriteRecordAccessor
rather than a ReadWriteRecordAccessor. |
AsyncMutableRecordStream<K> |
records()
Returns an
AsyncStream of the records in this dataset. |
Operation<java.lang.Boolean> |
update(K key,
UpdateOperation<? super K> transform)
An asynchronous equivalent to
DatasetWriterReader.update(Comparable, UpdateOperation) . |
get
default Operation<java.lang.Boolean> add(K key, Cell<?>... cells)
DatasetWriterReader.add(Comparable, Cell...)
.key
- key for the recordcells
- cells which form the recordOperation<java.lang.Boolean> add(K key, java.lang.Iterable<Cell<?>> cells)
DatasetWriterReader.add(Comparable, Iterable)
.key
- key for the recordcells
- a non-null
Iterable
supplying cells which form the recordjava.lang.NullPointerException
- if cells
is null
Operation<java.lang.Boolean> update(K key, UpdateOperation<? super K> transform)
DatasetWriterReader.update(Comparable, UpdateOperation)
.key
- key of the record to mutatetransform
- the mutating transformation to apply to the recordOperation<java.lang.Boolean> delete(K key)
DatasetWriterReader.delete(Comparable)
.key
- key of the record to removeAsyncReadWriteRecordAccessor<K> on(K key)
DatasetWriterReader.on(Comparable)
, but returns an AsyncReadWriteRecordAccessor
rather than a ReadWriteRecordAccessor.on
in interface AsyncDatasetReader<K extends java.lang.Comparable<K>>
key
- key of the recordAsyncMutableRecordStream<K> records()
AsyncDatasetReader
AsyncStream
of the records in this dataset.records
in interface AsyncDatasetReader<K extends java.lang.Comparable<K>>