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

Modifier and Type	Method and 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.