io.pravega.client.stream

Interface StreamCut

All Superinterfaces:

java.io.Serializable

public interface StreamCut
extends java.io.Serializable

A set of segment/offset pairs for a single stream that represent a consistent position in the stream. (IE: Segment 1 and 2 will not both appear in the set if 2 succeeds 1, and if 0 appears and is responsible for keyspace 0-0.5 then other segments covering the range 0.5-1.0 will also be included.)

Field Summary

Fields

Modifier and Type	Field and Description
static StreamCut	UNBOUNDED This is used represents an unbounded StreamCut.

Method Summary

Modifier and Type	Method and Description
io.pravega.client.stream.impl.StreamCutInternal	asImpl() Used internally.
static StreamCut	fromBytes(java.nio.ByteBuffer cut) Deserializes the cut from its serialized from obtained from calling toBytes().
java.nio.ByteBuffer	toBytes() Serializes the cut to a compact byte array.

Field Detail

UNBOUNDED

static final StreamCut UNBOUNDED

This is used represents an unbounded StreamCut. This is used when the user wants to refer to the current HEAD of the stream or the current TAIL of the stream.

Method Detail

asImpl

io.pravega.client.stream.impl.StreamCutInternal asImpl()

Used internally. Do not call.

Returns:

Implementation of EventPointer interface

toBytes

java.nio.ByteBuffer toBytes()

Serializes the cut to a compact byte array.

fromBytes

static StreamCut fromBytes(java.nio.ByteBuffer cut)

Deserializes the cut from its serialized from obtained from calling toBytes().

Parameters:

cut - A serialized position.

Returns:

The StreamCut object.