Package io.pravega.client.stream
-
Interface Summary Interface Description Checkpoint 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.EventStreamReader<T> A reader for a stream.EventStreamWriter<Type> A writer can write events to a stream.IdempotentEventStreamWriter<Type> A writer can write events to a stream.Position A position in a stream.ReaderGroup A reader group is a collection of readers that collectively read all the events in the stream.ReaderGroupMetrics 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.Stream A stream can be thought of as an unbounded sequence of events.StreamCut A set of segment/offset pairs for a single stream that represent a consistent position in the stream.Transaction<Type> Provides a mechanism for writing many events atomically.TransactionalEventStreamWriter<Type> A writer that writes Events to an Event stream transactionally.TransactionInfo TransactionInfo holds the information of transaction. -
Class Summary Class Description EventWriterConfig EventWriterConfig.EventWriterConfigBuilder ReaderConfig ReaderConfig.ReaderConfigBuilder ReaderGroupConfig ReaderGroupConfig.ReaderGroupConfigBuilder ReaderSegmentDistribution Describes current distribution of number of segments assigned to each reader in the reader group.ReaderSegmentDistribution.ReaderSegmentDistributionBuilder RetentionPolicy RetentionPolicy.RetentionPolicyBuilder ScalingPolicy A policy that specifies how the number of segments in a stream should scale over time.ScalingPolicy.ScalingPolicyBuilder Sequence A wrapper for two numbers.StreamConfiguration The configuration of a Stream.StreamConfiguration.StreamConfigurationBuilder TimeWindow Represents a time window for the events which are currently being read by a reader. -
Enum Summary Enum Description ReaderGroupConfig.StreamDataRetention If a Reader Group wants unconsumed data to be retained in a Stream, the retentionType inReaderGroupConfigshould be set to to 'MANUAL_RELEASE_AT_USER_STREAMCUT' or 'AUTOMATIC_RELEASE_AT_LAST_CHECKPOINT'.RetentionPolicy.RetentionType ScalingPolicy.ScaleType Transaction.PingStatus Transaction.Status -
Exception Summary Exception Description ConfigMismatchException ConfigMismatchException is thrown by theReaderGroupManager.createReaderGroup(String, ReaderGroupConfig)API when the reader group already exists with a different configuration.DeleteScopeFailedException Delete scope failed, typically because we failed to seal and delete the streams.InvalidStreamException NoSuchScopeException PingFailedException Transaction heartbeat to a controller instance failed, because of one of the following reasons.ReaderGroupNotFoundException ReaderGroupNotFoundException is thrown byReaderGroupManager.getReaderGroup(String)API when the provided reader group does not exist.ReaderNotInReaderGroupException Read was invoked on a reader that the reader group does not consider a member.ReinitializationRequiredException ReinitializationRequiredException is thrown byEventStreamReader.readNextEvent(long)API ifReaderGroup.resetReaderGroup(ReaderGroupConfig)was called, which requires readers to be reinitialized.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.