Package io.pravega.client.stream
Interface Stream
-
public interface Stream
A stream can be thought of as an unbounded sequence of events. A stream can be written to or read from. A stream is: Append only (Events in it are immutable once written) Unbounded (There are no limitations in how many events can go into a stream) Strongly Consistent (Events are either in the stream or they are not, and not subject to reordering once written) Scalable (The rate of events in a stream can greatly exceed the capacity of any single host)
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description java.lang.String
getScope()
Gets the scope of this stream.java.lang.String
getScopedName()
Gets the scoped name of this stream.java.lang.String
getStreamName()
Gets the name of this stream (Not including the scope).static Stream
of(java.lang.String scopedName)
Helper utility to create a Stream object from a scopedName of a Stream.static Stream
of(java.lang.String scope, java.lang.String streamName)
Helper utility to create a Stream object.
-
-
-
Method Detail
-
getScope
java.lang.String getScope()
Gets the scope of this stream.- Returns:
- String scope name
-
getStreamName
java.lang.String getStreamName()
Gets the name of this stream (Not including the scope).- Returns:
- String a stream name
-
getScopedName
java.lang.String getScopedName()
Gets the scoped name of this stream.- Returns:
- String a fully scoped stream name
-
of
static Stream of(java.lang.String scope, java.lang.String streamName)
Helper utility to create a Stream object.- Parameters:
scope
- Scope of the stream.streamName
- Name of the stream.- Returns:
- Stream.
-
of
static Stream of(java.lang.String scopedName)
Helper utility to create a Stream object from a scopedName of a Stream.- Parameters:
scopedName
- Scoped Name of the stream e.g: scopeName/streamName .- Returns:
- Stream.
-
-