PravegaStream

Stream (source) of events of elements.

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, the transaction id is completed in the promise.

The transaction is not committed or aborted by the writer, and can be used by other writers, localy or remotely.

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.

Sink that writes to a stream.

Stream (source) of elements.

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.

Writes atomicaly events to a stream.

Creates a ZPipeline that writes to a stream.