PravegaStreamManager is a wrapper around the StreamManager Java API.
Basically it's allow to create, drop, seal, truncate, etc. streams.
Attributes
- Companion
- object
- Graph
-
- Supertypes
-
class Objecttrait Matchableclass Any
Members list
Value members
Abstract methods
Create a stream with the given name and config. Note: This method is idempotent, may block.
Create a stream with the given name and config. Note: This method is idempotent, may block.
Will return false if the stream already exists, hence true if it was effectively created.
Attributes
Drop a scope with the given name. This method may block.
Drop a scope with the given name. This method may block.
Will return false if the scope does not exist, hence true if it was effectively dropped.
Attributes
Drop a stream with the given name. This method may block.
Drop a stream with the given name. This method may block.
Attributes
List all the scopes in the Pravega cluster. This method may block.
List all the scopes in the Pravega cluster. This method may block.
Attributes
Seal a stream with the given name. This method may block.
Seal a stream with the given name. This method may block.
Will return false if the stream does not exist, hence true if it was
Attributes
Truncate a stream with the given name. This method may block.
Truncate a stream with the given name. This method may block.