Pravega Stream API.
This API is a wrapper around the Pravega Java API. *
Attributes
- Companion
- object
- Graph
-
- Supertypes
-
class Objecttrait Matchableclass Any
Members list
Grouped members
Read
These methods are used to read from a stream.
Stream (source) of events of elements.
Stream (source) of events of elements.
Attributes
Stream (source) of elements.
Stream (source) of elements.
Attributes
Write
These methods are used to write to a stream, in atomic (transactional) or best effort mode.
Sink that writes to a transactional stream, transaction stays open after the sink is closed.
Sink that writes to a transactional stream, transaction stays open after the sink is closed.
The transaction id is provided by the caller.
The transaction may be committed by the writer.
Attributes
Sink that writes to a stream.
Sink that writes to a stream.
Attributes
Sink that writes to a transactional stream.
Sink that writes to a transactional stream.
Transaction is created by the writer, and committed or aborted by the writer regarding of the status of the stream scope.
Attributes
Sink that writes to a transactional stream, transaction stays open after the sink is closed.
Sink that writes to a transactional stream, transaction stays open after the sink is closed.
The transaction id is generated by the writer, once the transaction is effectively created, and materialized when the sink is closed.
The transaction is not committed or aborted by the writer, and can be used by other writers, localy or remotely.
Attributes
- Returns
-
The transaction id.
Writes atomicaly events to a stream.
Writes atomicaly events to a stream.
Attributes
Creates a ZPipeline that writes to a stream.
Creates a ZPipeline that writes to a stream.
Attributes
Writes events to a transactional stream, transaction is created but not committed.
Writes events to a transactional stream, transaction is created but not committed.
The transaction:
- is aborted in case of failure
- must be committed by the caller
Attributes
- Returns
-
transaction id