PravegaStream

Stream of events. See zio.pravega.PravegaStream.eventStream.

Stream of elements. See zio.pravega.PravegaStream.stream.

Sink that writes to an already opened transactional stream.

• The transaction id is provided by the caller.
• The transaction may be committed by the writer.
• The transaction is aborted by the writer in case of failure.

May commit the transaction on closing.

Open a transaction, and return its UUID. See zio.pravega.PravegaStream.writeUncommited.

Sink that writes to a stream. See zio.pravega.PravegaStream.sink.

This sink is not transactional, and does not guarantee that the events are written atomically.

Sink that writes to a transactional stream.

This sink is transactional, and guarantee that the events are written atomically, when the sink is closed.

Sink that writes to a transactional stream.

• The transaction id is generated by the writer, once the transaction is created.
• The transaction is not committed
• The transaction is aborted by the writer in case of failure.

It is the responsibility of the caller to commit the transaction see zio.pravega.PravegaStream.joinTransaction.

Writes atomicaly to a stream. See zio.pravega.PravegaStream.write.

Creates a ZPipeline that writes to a stream.

Writes to a stream transactional stream.

Transaction:

• is created and return when all item are written.
• will be aborted in case of failure.
• will not be committed.

It is the responsibility of the caller to commit the transaction see zio.pravega.PravegaStream.writeUncommited.

Creates a Pravega stream Service from a scope.

Requires a ClientConfig to be provided in the environment.

Creates a Pravega stream Service from a scope.