io.pravega.client.stream

Interface EventStreamReader<T>

Type Parameters:

T - The type of events being sent through this stream.

All Superinterfaces:

AutoCloseable

public interface EventStreamReader<T>
extends AutoCloseable

A reader for a stream.

This class is safe to use across threads, but doing so will not increase performance.

Method Summary

Modifier and Type	Method and Description
void	close() Close the reader.
ReaderConfig	getConfig() Gets the configuration that this reader was created with.
T	read(EventPointer pointer) Re-read an event that was previously read, by passing the pointer returned from EventRead.getEventPointer().
EventRead<T>	readNextEvent(long timeout) Gets the next event in the stream.

Method Detail

readNextEvent

EventRead<T> readNextEvent(long timeout)
                    throws ReinitializationRequiredException

Gets the next event in the stream. If there are no events currently available this will block up for timeout waiting for them to arrive. If none do, an EventRead will be returned with null for EventRead.getEvent(). (As well as for most other fields)

Parameters:

timeout - An upper bound on how long the call may block before returning null.

Returns:

An instance of EventRead, which contains the next event in the stream. In the case the timeout is reached, EventRead.getEvent() returns null.

Throws:

ReinitializationRequiredException - Is throw in the event that ReaderGroup.resetReadersToCheckpoint(Checkpoint) or ReaderGroup.updateConfig(ReaderGroupConfig, java.util.Set) was called which requires readers to be reinitialized.

getConfig

ReaderConfig getConfig()

Gets the configuration that this reader was created with.

Returns:

Reader configuration

read

T read(EventPointer pointer)
throws io.pravega.client.segment.impl.NoSuchEventException

Re-read an event that was previously read, by passing the pointer returned from EventRead.getEventPointer(). This does not affect the current position of the reader.

This is a blocking call. Passing invalid offsets has undefined behavior.

Parameters:

pointer - The pointer object to enable a random read of the event.

Returns:

The event at the position specified by the provided pointer or null if the event has been deleted.

Throws:

io.pravega.client.segment.impl.NoSuchEventException - Reader was not able to fetch the event.

close

void close()

Close the reader. No further actions may be performed. If this reader is part of a reader group, this will automatically invoke ReaderGroup.readerOffline(String, Position)

Specified by:

close in interface AutoCloseable

See Also:

AutoCloseable.close()