All Classes

Class	Description
AbstractNotifier<T extends Notification>	AbstractNotifier which is used by all types of Notifiers.
AbstractPollingNotifier<T extends Notification>
BadKeyVersionException	Exception that is thrown whenever a conditional KeyValueTable update failed due to the provided key version mismatching.
BatchClientFactory	Please note this is an experimental API.
ByteStreamClientFactory	Used to create Writers and Readers operating on a Byte Stream.
ByteStreamReader	Allows for reading raw bytes from a segment.
ByteStreamWriter	Allows for writing raw bytes directly to a segment.
Checkpoint
ClientConfig	This class contains configuration that is passed on to Pravega client.
ClientConfig.ClientConfigBuilder	This class overrides the lombok builder.
ConditionalTableUpdateException	Exception that is thrown whenever a Conditional Update to a KeyValueTable failed.
ConfigMismatchException	ConfigMismatchException is thrown by the ReaderGroupManager.createReaderGroup(String, ReaderGroupConfig) API when the reader group already exists with a different configuration.
DelegationTokenProvider	A client-side proxy for obtaining a delegation token from the server.
DelegationTokenProviderFactory	Factory class for DelegationTokenProvider instances.
DeleteScopeFailedException	Delete scope failed, typically because we failed to seal and delete the streams.
EmptyTokenProviderImpl	Provides empty delegation tokens.
EndOfDataNotification	Class to represent a end of data notification.
EndOfDataNotifier
EventPointer	A pointer to an event.
EventRead<T>	An event that was read from a stream or a checkpoint marker if one has been requested.
EventStreamClientFactory	Used to create Writers and Readers operating on a stream.
EventStreamReader<T>	A reader for a stream.
EventStreamWriter<Type>	A writer can write events to a stream.
EventWriterConfig
EventWriterConfig.EventWriterConfigBuilder
IdempotentEventStreamWriter<Type>	A writer can write events to a stream.
InitialUpdate<StateT extends Revisioned>	A constructor for a StateT object.
Insert	Represents an Insertion of a TableKey (with a value) into a KeyValueTable.
InvalidStreamException
IteratorItem<T>	An iteration result item returned by AsyncIterator when invoking KeyValueTable.iterator().
JwtTokenProviderImpl	Provides JWT-based delegation tokens.
KeyValueTable	Defines all operations that are supported on a Key-Value Table.
KeyValueTableClientConfiguration	Configuration for the KeyValueTable client.
KeyValueTableClientConfiguration.KeyValueTableClientConfigurationBuilder
KeyValueTableConfiguration	The configuration of a Key-Value Table.
KeyValueTableConfiguration.KeyValueTableConfigurationBuilder
KeyValueTableFactory	Creates instances of KeyValueTable.
KeyValueTableInfo	Information about a Key-Value Table.
KeyValueTableIterator	Defines a preconfigured Iterator for a KeyValueTable, which can be used to iterate over TableKey or TableEntry instances.
KeyValueTableIterator.Builder	Defines a Builder for a KeyValueTableIterator.
KeyValueTableManager	Used to create, delete and manage Key-Value Tables.
KeyVersion	Version of a Key in a Table.
Listener<T>	Listener interface for receiving notifications.
NoSuchKeyException	Exception that is thrown whenever a conditional KeyValueTable update failed due to the key not existing.
NoSuchScopeException
Notification	Represents base notification type.
NotificationSystem
NotifierFactory	Factory used to create different types of notifiers.
Observable<T>	This represents an observable notification.
PingFailedException	Transaction heartbeat to a controller instance failed, because of one of the following reasons.
Position	A position in a stream.
Put	Updates the Value associated with a TableKey in a KeyValueTable.
ReaderConfig
ReaderConfig.ReaderConfigBuilder
ReaderGroup	A reader group is a collection of readers that collectively read all the events in the stream.
ReaderGroupConfig
ReaderGroupConfig.ReaderGroupConfigBuilder
ReaderGroupConfig.StreamDataRetention	If a Reader Group wants unconsumed data to be retained in a Stream, the retentionType in ReaderGroupConfig should be set to to 'MANUAL_RELEASE_AT_USER_STREAMCUT' or 'AUTOMATIC_RELEASE_AT_LAST_CHECKPOINT'.
ReaderGroupManager	Used to create and manage reader groups.
ReaderGroupMetrics
ReaderGroupNotFoundException	ReaderGroupNotFoundException is thrown by ReaderGroupManager.getReaderGroup(String) API when the provided reader group does not exist.
ReaderGroupNotificationListener	ReaderGroup notification listener interface.
ReaderNotInReaderGroupException	Read was invoked on a reader that the reader group does not consider a member.
ReaderSegmentDistribution	Describes current distribution of number of segments assigned to each reader in the reader group.
ReaderSegmentDistribution.ReaderSegmentDistributionBuilder
ReinitializationRequiredException	ReinitializationRequiredException is thrown by EventStreamReader.readNextEvent(long) API if ReaderGroup.resetReaderGroup(ReaderGroupConfig) was called, which requires readers to be reinitialized.
Remove	Removes a TableKey from a KeyValueTable.
RetentionPolicy
RetentionPolicy.RetentionPolicyBuilder
RetentionPolicy.RetentionType
Revision	A maker for a version of a Revisioned object.
Revisioned	An object that has a revision associated with it.
RevisionedStreamClient<T>	Provides a stream that can be read and written to with strong consistency.
ScalingPolicy	A policy that specifies how the number of segments in a stream should scale over time.
ScalingPolicy.ScaleType
ScalingPolicy.ScalingPolicyBuilder
SegmentIterator<T>	Please note this is an experimental API.
SegmentNotification	Class to represent a segment notification.
SegmentNotification.SegmentNotificationBuilder
SegmentNotifier
SegmentRange	This is used to represent range bounded portion of a Segment.
Sequence	A wrapper for two numbers.
Serializer<T>	Takes events being written and serializes them to byteBuffers so they can be sent over the wire and deserializes these same byte buffers back into objects.
StateSynchronizer<StateT extends Revisioned>	Provides a means to have state that is synchronized between many processes.
StateSynchronizer.UpdateGenerator<StateT extends Revisioned>	A function which given a state object populates a list of updates that should be applied.
StateSynchronizer.UpdateGeneratorFunction<StateT extends Revisioned,ReturnT>	Similar to StateSynchronizer.UpdateGenerator but it also returns a result for the caller.
Stream	A stream can be thought of as an unbounded sequence of events.
StreamConfiguration	The configuration of a Stream.
StreamConfiguration.StreamConfigurationBuilder
StreamCut	A set of segment/offset pairs for a single stream that represent a consistent position in the stream.
StreamInfo	This class is used to represent Stream information.
StreamManager	Used to create, delete, and manage Streams and ReaderGroups.
StreamSegmentsIterator
StringTokenProviderImpl	A provider for handling non-JWT, non-empty delegation tokens.
SynchronizerClientFactory	Used to create StateSynchronizer and RevisionedStreamClient objects which allow for reading and writing data from a pre-configured stream with strong consistency guarantees.
SynchronizerConfig	The configuration for a Consistent replicated state synchronizer.
SynchronizerConfig.SynchronizerConfigBuilder
TableEntry	A KeyValueTable Entry.
TableEntryUpdate	Defines a TableModification that updates a TableKey with a new value.
TableKey	A KeyValueTable Key.
TableModification	Defines a modification that can be applied to a TableKey in a KeyValueTable.
TimeWindow	Represents a time window for the events which are currently being read by a reader.
Transaction<Type>	Provides a mechanism for writing many events atomically.
Transaction.PingStatus
Transaction.Status
TransactionalEventStreamWriter<Type>	A writer that writes Events to an Event stream transactionally.
TransactionInfo	TransactionInfo holds the information of transaction.
TruncatedDataException	TruncatedDataException is thrown if the data to be read next has been truncated away and can no longer be read.
TxnFailedException	A transaction has failed.
Update<StateT extends Revisioned>	An update to a StateT object coordinated via a StateSynchronizer.
Version	Version of a Key in a Table.
WatermarkSerializer