Index (Pravega API)

A B C D E F G H I J K L M N O P R S T U V W
All Classes All Packages

A

abort() - Method in interface io.pravega.client.stream.Transaction: Drops the transaction, causing all events written to it to be deleted.
ABORTED - io.pravega.client.stream.Transaction.PingStatus
ABORTED - io.pravega.client.stream.Transaction.Status
ABORTING - io.pravega.client.stream.Transaction.Status
AbstractNotifier<T extends Notification> - Class in io.pravega.client.stream.notifications.notifier: AbstractNotifier which is used by all types of Notifiers.
AbstractNotifier(NotificationSystem, ScheduledExecutorService) - Constructor for class io.pravega.client.stream.notifications.notifier.AbstractNotifier
AbstractPollingNotifier<T extends Notification> - Class in io.pravega.client.stream.notifications.notifier
addListeners(String, Listener<T>, ScheduledExecutorService) - Method in class io.pravega.client.stream.notifications.NotificationSystem
all() - Method in interface io.pravega.client.tables.KeyValueTableIterator.Builder: Creates a new KeyValueTableIterator that returns all the TableKey/TableEntry instances in the associated KeyValueTable.
applyTo(StateT, Revision) - Method in interface io.pravega.client.state.InitialUpdate
applyTo(StateT, Revision) - Method in interface io.pravega.client.state.Update: Return an object of type StateT that is the same as oldState with this update applied to it.
asImpl() - Method in interface io.pravega.client.batch.SegmentRange: For internal use.
asImpl() - Method in interface io.pravega.client.batch.StreamSegmentsIterator: For internal use.
asImpl() - Method in interface io.pravega.client.state.Revision: Returns the actual instance.
asImpl() - Method in interface io.pravega.client.stream.Checkpoint: For internal use.
asImpl() - Method in interface io.pravega.client.stream.EventPointer: Used internally.
asImpl() - Method in interface io.pravega.client.stream.Position: Used internally.
asImpl() - Method in interface io.pravega.client.stream.StreamCut: Used internally.
asImpl() - Method in interface io.pravega.client.tables.Version: Returns the actual instance.
asText() - Method in interface io.pravega.client.stream.StreamCut: Obtains the compact base64 string representation of StreamCut.
AUTOMATIC_RELEASE_AT_LAST_CHECKPOINT - io.pravega.client.stream.ReaderGroupConfig.StreamDataRetention
automaticallyNoteTime(boolean) - Method in class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder: Automatically invoke EventStreamWriter.noteTime(long) passing System.currentTimeMillis() on a regular interval.
automaticCheckpointIntervalMillis(long) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder
available() - Method in class io.pravega.client.byteStream.ByteStreamReader: Returns the number of bytes that can be read without blocking.

B

backoffMultiple(int) - Method in class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder: Backoff multiplier used in the retry logic of the writer.
backoffMultiple(int) - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration.KeyValueTableClientConfigurationBuilder
BadKeyVersionException - Exception in io.pravega.client.tables: Exception that is thrown whenever a conditional KeyValueTable update failed due to the provided key version mismatching.
BadKeyVersionException(String) - Constructor for exception io.pravega.client.tables.BadKeyVersionException: Creates a new instance of the BadKeyVersionException class.
BadKeyVersionException(String, String) - Constructor for exception io.pravega.client.tables.BadKeyVersionException: Creates a new instance of the BadKeyVersionException class.
BatchClientFactory - Interface in io.pravega.client: Please note this is an experimental API.
beginTxn() - Method in interface io.pravega.client.stream.TransactionalEventStreamWriter: Start a new transaction on this stream.
bufferSize(int) - Method in class io.pravega.client.stream.ReaderConfig.ReaderConfigBuilder
build() - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder
build() - Method in class io.pravega.client.state.SynchronizerConfig.SynchronizerConfigBuilder
build() - Method in class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder
build() - Method in class io.pravega.client.stream.notifications.SegmentNotification.SegmentNotificationBuilder
build() - Method in class io.pravega.client.stream.ReaderConfig.ReaderConfigBuilder
build() - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder
build() - Method in class io.pravega.client.stream.ReaderSegmentDistribution.ReaderSegmentDistributionBuilder
build() - Method in class io.pravega.client.stream.RetentionPolicy.RetentionPolicyBuilder
build() - Method in class io.pravega.client.stream.ScalingPolicy.ScalingPolicyBuilder
build() - Method in class io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder
build() - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration.KeyValueTableClientConfigurationBuilder
build() - Method in class io.pravega.client.tables.KeyValueTableConfiguration.KeyValueTableConfigurationBuilder
builder() - Static method in class io.pravega.client.ClientConfig
builder() - Static method in class io.pravega.client.state.SynchronizerConfig
builder() - Static method in class io.pravega.client.stream.EventWriterConfig
builder() - Static method in class io.pravega.client.stream.notifications.SegmentNotification
builder() - Static method in class io.pravega.client.stream.ReaderConfig
builder() - Static method in class io.pravega.client.stream.ReaderGroupConfig
builder() - Static method in class io.pravega.client.stream.ReaderSegmentDistribution
builder() - Static method in class io.pravega.client.stream.RetentionPolicy
builder() - Static method in class io.pravega.client.stream.ScalingPolicy
builder() - Static method in class io.pravega.client.stream.StreamConfiguration
builder() - Static method in class io.pravega.client.tables.KeyValueTableClientConfiguration
builder() - Static method in class io.pravega.client.tables.KeyValueTableConfiguration
BY_RATE_IN_EVENTS_PER_SEC - io.pravega.client.stream.ScalingPolicy.ScaleType: Scale based on the rate in events specified in ScalingPolicy.targetRate.
BY_RATE_IN_KBYTES_PER_SEC - io.pravega.client.stream.ScalingPolicy.ScaleType: Scale based on the rate in bytes specified in ScalingPolicy.targetRate.
byDataRate(int, int, int) - Static method in class io.pravega.client.stream.ScalingPolicy: Create a scaling policy to configure a stream to scale up and down according to byte rate.
byEventRate(int, int, int) - Static method in class io.pravega.client.stream.ScalingPolicy: Create a scaling policy to configure a stream to scale up and down according to event rate.
bySizeBytes(long) - Static method in class io.pravega.client.stream.RetentionPolicy: Create a retention policy to configure a stream to truncate a stream according to the amount of data currently stored.
bySizeBytes(long, long) - Static method in class io.pravega.client.stream.RetentionPolicy: Create a retention policy to configure a stream to truncate a stream according to the amount of data currently stored.
ByteStreamClientFactory - Interface in io.pravega.client: Used to create Writers and Readers operating on a Byte Stream.
ByteStreamReader - Class in io.pravega.client.byteStream: Allows for reading raw bytes from a segment.
ByteStreamReader() - Constructor for class io.pravega.client.byteStream.ByteStreamReader
ByteStreamWriter - Class in io.pravega.client.byteStream: Allows for writing raw bytes directly to a segment.
ByteStreamWriter() - Constructor for class io.pravega.client.byteStream.ByteStreamWriter
bytesWrittenSinceCompaction() - Method in interface io.pravega.client.state.StateSynchronizer: Calculates the number of bytes that have been written since the state has last been compacted by calling StateSynchronizer.compact(Function) This may be useful when calculating when a compaction should occur.
byTime(Duration) - Static method in class io.pravega.client.stream.RetentionPolicy: Create a retention policy to configure a stream to be periodically truncated according to the specified duration.
byTime(Duration, Duration) - Static method in class io.pravega.client.stream.RetentionPolicy: Create a retention policy to configure a stream to periodically truncated according to the specified duration.

C

cancelOutstandingCheckpoints() - Method in interface io.pravega.client.stream.ReaderGroup: Cancels the outStanding checkpoints.
canEqual(Object) - Method in class io.pravega.client.admin.KeyValueTableInfo
canEqual(Object) - Method in class io.pravega.client.admin.StreamInfo
canEqual(Object) - Method in class io.pravega.client.ClientConfig
canEqual(Object) - Method in class io.pravega.client.state.SynchronizerConfig
canEqual(Object) - Method in class io.pravega.client.stream.EventWriterConfig
canEqual(Object) - Method in class io.pravega.client.stream.notifications.Notification
canEqual(Object) - Method in class io.pravega.client.stream.notifications.SegmentNotification
canEqual(Object) - Method in class io.pravega.client.stream.ReaderConfig
canEqual(Object) - Method in class io.pravega.client.stream.ReaderGroupConfig
canEqual(Object) - Method in class io.pravega.client.stream.RetentionPolicy
canEqual(Object) - Method in class io.pravega.client.stream.ScalingPolicy
canEqual(Object) - Method in class io.pravega.client.stream.Sequence
canEqual(Object) - Method in class io.pravega.client.stream.StreamConfiguration
canEqual(Object) - Method in class io.pravega.client.stream.TimeWindow
canEqual(Object) - Method in class io.pravega.client.tables.IteratorItem
canEqual(Object) - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration
canEqual(Object) - Method in class io.pravega.client.tables.KeyValueTableConfiguration
Checkpoint - Interface in io.pravega.client.stream
checkScopeExists(String) - Method in interface io.pravega.client.admin.StreamManager: Checks if a scope exists.
checkStatus() - Method in interface io.pravega.client.stream.Transaction: Gets the status of the transaction.
checkStreamExists(String, String) - Method in interface io.pravega.client.admin.StreamManager: Checks if a stream exists in scope.
clearTags() - Method in class io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder
ClientConfig - Class in io.pravega.client: This class contains configuration that is passed on to Pravega client.
ClientConfig.ClientConfigBuilder - Class in io.pravega.client: This class overrides the lombok builder.
cloneConfig(ReaderGroupConfig, UUID, long) - Static method in class io.pravega.client.stream.ReaderGroupConfig
close() - Method in interface io.pravega.client.admin.KeyValueTableManager: Closes the KeyValueTableManager.
close() - Method in interface io.pravega.client.admin.ReaderGroupManager: Close this manager class.
close() - Method in interface io.pravega.client.admin.StreamManager: Closes the stream manager.
close() - Method in interface io.pravega.client.batch.SegmentIterator: Closes the iterator, freeing any resources associated with it.
close() - Method in interface io.pravega.client.BatchClientFactory: Closes the client factory.
close() - Method in class io.pravega.client.byteStream.ByteStreamReader: Closes the reader.
close() - Method in class io.pravega.client.byteStream.ByteStreamWriter: Flushes the buffer and closes the writer.
close() - Method in interface io.pravega.client.ByteStreamClientFactory: Closes the ByteStreamClientFactory.
close() - Method in interface io.pravega.client.EventStreamClientFactory: Closes the client factory.
close() - Method in interface io.pravega.client.KeyValueTableFactory: Closes the KeyValueTableFactory.
close() - Method in interface io.pravega.client.state.RevisionedStreamClient: Closes the client and frees any resources associated with it.
close() - Method in interface io.pravega.client.state.StateSynchronizer: Closes the StateSynchronizer and frees any resources associated with it.
close() - Method in interface io.pravega.client.stream.EventStreamReader: Close the reader.
close() - Method in interface io.pravega.client.stream.EventStreamWriter: Calls flush and then closes the writer.
close() - Method in interface io.pravega.client.stream.IdempotentEventStreamWriter: Calls flush and then closes the writer.
close() - Method in interface io.pravega.client.stream.ReaderGroup: Closes the reader group, freeing any resources associated with it.
close() - Method in interface io.pravega.client.stream.TransactionalEventStreamWriter: Closes the writer.
close() - Method in interface io.pravega.client.SynchronizerClientFactory: Closes the client factory.
close() - Method in interface io.pravega.client.tables.KeyValueTable: Closes the KeyValueTable.
closeAndSeal() - Method in class io.pravega.client.byteStream.ByteStreamWriter: Closes the writer similar to ByteStreamWriter.close() but also seals it so that no future writes can ever be made.
closeAt(Position) - Method in interface io.pravega.client.stream.EventStreamReader: Close the reader at a specific position.
commit() - Method in interface io.pravega.client.stream.Transaction: Causes all messages previously written to the transaction to go into the stream contiguously.
commit(long) - Method in interface io.pravega.client.stream.Transaction: Commits the transaction similar to Transaction.commit(), but also notes an associated timestamp.
COMMITTED - io.pravega.client.stream.Transaction.PingStatus
COMMITTED - io.pravega.client.stream.Transaction.Status
COMMITTING - io.pravega.client.stream.Transaction.Status
compact(Function<StateT, InitialUpdate<StateT>>) - Method in interface io.pravega.client.state.StateSynchronizer: Provide a function that generates compacted version of localState so that we can drop some of the history updates.
compareAndSetMark(Revision, Revision) - Method in interface io.pravega.client.state.RevisionedStreamClient: Records a provided location that can later be obtained by calling RevisionedStreamClient.getMark().
compareTo(Sequence) - Method in class io.pravega.client.stream.Sequence
ConditionalTableUpdateException - Exception in io.pravega.client.tables: Exception that is thrown whenever a Conditional Update to a KeyValueTable failed.
ConditionalTableUpdateException(String) - Constructor for exception io.pravega.client.tables.ConditionalTableUpdateException: Creates a new instance of the ConditionalTableUpdateException class.
ConditionalTableUpdateException(String, String) - Constructor for exception io.pravega.client.tables.ConditionalTableUpdateException: Creates a new instance of the ConditionalTableUpdateException class.
ConfigMismatchException - Exception in io.pravega.client.stream: ConfigMismatchException is thrown by the ReaderGroupManager.createReaderGroup(String, ReaderGroupConfig) API when the reader group already exists with a different configuration.
ConfigMismatchException(String, ReaderGroupConfig) - Constructor for exception io.pravega.client.stream.ConfigMismatchException
connectTimeoutMilliSec(long) - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder: Sets the connection timeout in milliseconds for establishing connections.
controllerURI(URI) - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder: controllerURI The controller rpc URI.
create(long, long) - Static method in class io.pravega.client.stream.Sequence
create(ClientConfig) - Static method in interface io.pravega.client.admin.KeyValueTableManager: Creates a new instance of KeyValueTableManager.
create(ClientConfig) - Static method in interface io.pravega.client.admin.StreamManager: Creates a new instance of StreamManager.
create(Controller, Segment, AccessOperation) - Static method in class io.pravega.client.security.auth.DelegationTokenProviderFactory: Creates a DelegationTokenProvider instance with null delegation token.
create(Controller, String, String, AccessOperation) - Static method in class io.pravega.client.security.auth.DelegationTokenProviderFactory: Creates a DelegationTokenProvider instance with null delegation token.
create(String, Controller, Segment, AccessOperation) - Static method in class io.pravega.client.security.auth.DelegationTokenProviderFactory: Creates a DelegationTokenProvider instance with the specified delegation token.
create(String, Controller, String, String, AccessOperation) - Static method in class io.pravega.client.security.auth.DelegationTokenProviderFactory: Creates a DelegationTokenProvider instance of an appropriate type.
create(String, Revision) - Method in interface io.pravega.client.state.InitialUpdate: Returns an object of type StateT with the provided revision.
create(URI) - Static method in interface io.pravega.client.admin.KeyValueTableManager: Creates a new instance of KeyValueTableManager.
create(URI) - Static method in interface io.pravega.client.admin.StreamManager: Creates a new instance of StreamManager.
createByteStreamReader(String) - Method in interface io.pravega.client.ByteStreamClientFactory: Creates a new ByteStreamReader on the specified stream initialized with the last offset which was passed to ByteStreamWriter::truncateDataBefore(offset), or 0 if truncateDataBefore has not ever been called on this stream.
createByteStreamWriter(String) - Method in interface io.pravega.client.ByteStreamClientFactory: Creates a new ByteStreamWriter on the specified stream.
createEventWriter(String, Serializer<T>, EventWriterConfig) - Method in interface io.pravega.client.EventStreamClientFactory: Creates a new writer that can write to the specified stream.
createEventWriter(String, String, Serializer<T>, EventWriterConfig) - Method in interface io.pravega.client.EventStreamClientFactory: Creates a new writer that can write to the specified stream.
createKeyValueTable(String, String, KeyValueTableConfiguration) - Method in interface io.pravega.client.admin.KeyValueTableManager: Creates a new Key-Value Table.
createReader(String, String, Serializer<T>, ReaderConfig) - Method in interface io.pravega.client.EventStreamClientFactory: Creates (or recreates) a new reader that is part of a ReaderGroup.
createReaderGroup(String, ReaderGroupConfig) - Method in interface io.pravega.client.admin.ReaderGroupManager: Creates a new ReaderGroup.
createRevisionedStreamClient(String, Serializer<T>, SynchronizerConfig) - Method in interface io.pravega.client.SynchronizerClientFactory: Creates a new RevisionedStreamClient that will work with the specified stream.
createScope(String) - Method in interface io.pravega.client.admin.StreamManager: Creates a new scope.
createStateSynchronizer(String, Serializer<UpdateT>, Serializer<InitT>, SynchronizerConfig) - Method in interface io.pravega.client.SynchronizerClientFactory: Creates a new StateSynchronizer that will work on the specified stream.
createStream(String, String, StreamConfiguration) - Method in interface io.pravega.client.admin.StreamManager: Creates a new stream
createTransactionalEventWriter(String, Serializer<T>, EventWriterConfig) - Method in interface io.pravega.client.EventStreamClientFactory: Creates a new transactional writer that can write to the specified stream atomically.
createTransactionalEventWriter(String, String, Serializer<T>, EventWriterConfig) - Method in interface io.pravega.client.EventStreamClientFactory: Creates a new transactional writer that can write to the specified stream atomically.
createWithEmptyToken() - Static method in class io.pravega.client.security.auth.DelegationTokenProviderFactory: Creates a DelegationTokenProvider instance with empty token.
credentials(Credentials) - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder: Credentials to be passed on to the Pravega controller for authentication and authorization.

D

DEFAULT_GENERATION - Static variable in class io.pravega.client.stream.ReaderGroupConfig
DEFAULT_UUID - Static variable in class io.pravega.client.stream.ReaderGroupConfig
DelegationTokenProvider - Interface in io.pravega.client.security.auth: A client-side proxy for obtaining a delegation token from the server.
DelegationTokenProviderFactory - Class in io.pravega.client.security.auth: Factory class for DelegationTokenProvider instances.
DelegationTokenProviderFactory() - Constructor for class io.pravega.client.security.auth.DelegationTokenProviderFactory
deleteKeyValueTable(String, String) - Method in interface io.pravega.client.admin.KeyValueTableManager: Deletes the provided Key-Value Table.
deleteReaderGroup(String) - Method in interface io.pravega.client.admin.ReaderGroupManager: Deletes a reader group, removing any state associated with it.
deleteScope(String) - Method in interface io.pravega.client.admin.StreamManager: Deletes an existing scope.
deleteScope(String, boolean) - Method in interface io.pravega.client.admin.StreamManager: Deprecated.
As of Pravega release 0.11.0, replaced by StreamManager.deleteScopeRecursive(String).
DeleteScopeFailedException - Exception in io.pravega.client.stream: Delete scope failed, typically because we failed to seal and delete the streams.
DeleteScopeFailedException(String, Throwable) - Constructor for exception io.pravega.client.stream.DeleteScopeFailedException
deleteScopeRecursive(String) - Method in interface io.pravega.client.admin.StreamManager: Deletes scope by listing and deleting all streams/RGs/KVTs in scope.
deleteStream(String, String) - Method in interface io.pravega.client.admin.StreamManager: Deletes the provided stream.
deserialize(ByteBuffer) - Method in interface io.pravega.client.stream.Serializer: Deserializes the given ByteBuffer into an event.
deserialize(ByteBuffer) - Method in class io.pravega.client.watermark.WatermarkSerializer
disableAutomaticCheckpoints() - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder: Disables automatic checkpointing.
disableTimeWindows(boolean) - Method in class io.pravega.client.stream.ReaderConfig.ReaderConfigBuilder

E

EmptyTokenProviderImpl - Class in io.pravega.client.security.auth: Provides empty delegation tokens.
EmptyTokenProviderImpl() - Constructor for class io.pravega.client.security.auth.EmptyTokenProviderImpl
enableConnectionPooling(boolean) - Method in class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder: Enable or disable connection pooling for writer.
enableLargeEvents(boolean) - Method in class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder: Enable or disable whether LargeEvent writes should be processed and sent to the SegmentStore.
enableTlsToController(boolean) - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder
enableTlsToSegmentStore(boolean) - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder
endingStreamCuts(Map<Stream, StreamCut>) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder
EndOfDataNotification - Class in io.pravega.client.stream.notifications: Class to represent a end of data notification.
EndOfDataNotification() - Constructor for class io.pravega.client.stream.notifications.EndOfDataNotification
EndOfDataNotifier - Class in io.pravega.client.stream.notifications.notifier
EndOfDataNotifier(NotificationSystem, StateSynchronizer<ReaderGroupState>, ScheduledExecutorService) - Constructor for class io.pravega.client.stream.notifications.notifier.EndOfDataNotifier
entries() - Method in interface io.pravega.client.tables.KeyValueTableIterator: Creates a new Iterator over TableEntry instances in the associated KeyValueTable.
equals(Object) - Method in class io.pravega.client.admin.KeyValueTableInfo
equals(Object) - Method in class io.pravega.client.admin.StreamInfo
equals(Object) - Method in class io.pravega.client.ClientConfig
equals(Object) - Method in class io.pravega.client.state.SynchronizerConfig
equals(Object) - Method in class io.pravega.client.stream.EventWriterConfig
equals(Object) - Method in class io.pravega.client.stream.notifications.Notification
equals(Object) - Method in class io.pravega.client.stream.notifications.SegmentNotification
equals(Object) - Method in class io.pravega.client.stream.ReaderConfig
equals(Object) - Method in class io.pravega.client.stream.ReaderGroupConfig
equals(Object) - Method in class io.pravega.client.stream.RetentionPolicy
equals(Object) - Method in class io.pravega.client.stream.ScalingPolicy
equals(Object) - Method in class io.pravega.client.stream.Sequence
equals(Object) - Method in class io.pravega.client.stream.StreamConfiguration
equals(Object) - Method in class io.pravega.client.stream.TimeWindow
equals(Object) - Method in class io.pravega.client.tables.IteratorItem
equals(Object) - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration
equals(Object) - Method in class io.pravega.client.tables.KeyValueTableConfiguration
equals(Object) - Method in class io.pravega.client.tables.TableEntry
equals(Object) - Method in class io.pravega.client.tables.TableKey
EventPointer - Interface in io.pravega.client.stream: A pointer to an event.
EventRead<T> - Interface in io.pravega.client.stream: An event that was read from a stream or a checkpoint marker if one has been requested.
EventStreamClientFactory - Interface in io.pravega.client: Used to create Writers and Readers operating on a stream.
EventStreamReader<T> - Interface in io.pravega.client.stream: A reader for a stream.
EventStreamWriter<Type> - Interface in io.pravega.client.stream: A writer can write events to a stream.
eventWriterConfig(EventWriterConfig) - Method in class io.pravega.client.state.SynchronizerConfig.SynchronizerConfigBuilder: This writer config is used by the segment writers in the StateSynchronizer.
EventWriterConfig - Class in io.pravega.client.stream
EventWriterConfig.EventWriterConfigBuilder - Class in io.pravega.client.stream
executor - Variable in class io.pravega.client.stream.notifications.notifier.AbstractNotifier
exists(TableKey) - Method in interface io.pravega.client.tables.KeyValueTable: Determines if the given TableKey exists or not.

F

fetchEvent(EventPointer) - Method in interface io.pravega.client.stream.EventStreamReader: Re-read an event that was previously read, by passing the pointer returned from EventRead.getEventPointer().
fetchEvent(EventPointer, Serializer<T>) - Method in interface io.pravega.client.admin.StreamManager: Re-read an event that was previously read, by passing the pointer returned from EventRead.getEventPointer().
fetchHeadOffset() - Method in class io.pravega.client.byteStream.ByteStreamReader: This makes a synchronous RPC call to the server to obtain the current head of the stream.
fetchHeadOffset() - Method in class io.pravega.client.byteStream.ByteStreamWriter: This makes a synchronous RPC call to the server to obtain the current head of the stream.
fetchLatestRevision() - Method in interface io.pravega.client.state.RevisionedStreamClient: Returns the latest revision.
fetchOldestRevision() - Method in interface io.pravega.client.state.RevisionedStreamClient: Returns the oldest revision that reads can start from.
fetchStreamInfo(String, String) - Method in interface io.pravega.client.admin.StreamManager: Fetch information about a given Stream StreamInfo from server asynchronously.
fetchTailOffset() - Method in class io.pravega.client.byteStream.ByteStreamReader: This make an RPC to the server to fetch the offset at which new bytes would be written.
fetchTailOffset() - Method in class io.pravega.client.byteStream.ByteStreamWriter: This makes a synchronous RPC call to the server to obtain the total number of bytes written to the segment in its history.
fetchUpdates() - Method in interface io.pravega.client.state.StateSynchronizer: Fetch and apply all updates needed to the state object held locally up to date.
fixed(int) - Static method in class io.pravega.client.stream.ScalingPolicy: Create a scaling policy to configure a stream to have a fixed number of segments.
FIXED_NUM_SEGMENTS - io.pravega.client.stream.ScalingPolicy.ScaleType: No scaling, there will only ever be ScalingPolicy.minNumSegments at any given time.
flush() - Method in class io.pravega.client.byteStream.ByteStreamWriter: Blocks until all data written has been durably persisted.
flush() - Method in interface io.pravega.client.stream.EventStreamWriter: Block until all events that have been passed to writeEvent's corresponding futures have completed.
flush() - Method in interface io.pravega.client.stream.IdempotentEventStreamWriter: Block until all events that have been passed to writeEvent's corresponding futures have completed.
flush() - Method in interface io.pravega.client.stream.Transaction: Blocks until all events passed to Transaction.writeEvent(String, Object) make it to durable storage.
flushAsync() - Method in class io.pravega.client.byteStream.ByteStreamWriter: The future will complete successfully when all data which was passed to the write prior to calling this method has been persisted, and will complete exceptionally if that is not possible such as for example if the segment is sealed.
forKeyValueTable(String, KeyValueTableClientConfiguration) - Method in interface io.pravega.client.KeyValueTableFactory: Creates a new KeyValueTable that provides access to a Pravega Key-Value Table.
forPrefix(ByteBuffer) - Method in interface io.pravega.client.tables.KeyValueTableIterator.Builder: Creates a new KeyValueTableIterator that returns TableKey/TableEntry instances with Primary Keys (see TableKey.getPrimaryKey() that begin with the given prefix.
forPrimaryKey(ByteBuffer) - Method in interface io.pravega.client.tables.KeyValueTableIterator.Builder: Creates a new KeyValueTableIterator that returns TableKey/TableEntry instances with the same Primary Key (see TableKey.getPrimaryKey().
forPrimaryKey(ByteBuffer, ByteBuffer) - Method in interface io.pravega.client.tables.KeyValueTableIterator.Builder: Creates a new KeyValueTableIterator that returns TableKey/TableEntry instances with the same Primary Key (see TableKey.getPrimaryKey() and all Secondary keys (see TableKey.getSecondaryKey()) that begin with the given prefix.
forPrimaryKey(ByteBuffer, ByteBuffer, ByteBuffer) - Method in interface io.pravega.client.tables.KeyValueTableIterator.Builder: Creates a new KeyValueTableIterator that returns TableKey/TableEntry instances with the same Primary Key (see TableKey.getPrimaryKey().
forRange(ByteBuffer, ByteBuffer) - Method in interface io.pravega.client.tables.KeyValueTableIterator.Builder: Creates a new KeyValueTableIterator that returns TableKey/TableEntry instances with Primary Keys (see TableKey.getPrimaryKey() between the two values.
from(String) - Static method in interface io.pravega.client.stream.StreamCut: Obtains the a StreamCut object from its Base64 representation obtained via StreamCut.asText().
fromBytes(ByteBuffer) - Static method in class io.pravega.client.state.SynchronizerConfig
fromBytes(ByteBuffer) - Static method in interface io.pravega.client.stream.Checkpoint: Deserializes the checkpoint from its serialized from obtained from calling Checkpoint.toBytes().
fromBytes(ByteBuffer) - Static method in interface io.pravega.client.stream.EventPointer: Deserializes the event pointer from its serialized from obtained from calling EventPointer.toBytes().
fromBytes(ByteBuffer) - Static method in class io.pravega.client.stream.EventWriterConfig
fromBytes(ByteBuffer) - Static method in interface io.pravega.client.stream.Position: Deserializes the position from its serialized from obtained from calling Position.toBytes().
fromBytes(ByteBuffer) - Static method in class io.pravega.client.stream.ReaderGroupConfig
fromBytes(ByteBuffer) - Static method in interface io.pravega.client.stream.StreamCut: Deserializes the cut from its serialized from obtained from calling StreamCut.toBytes().
fromString(String) - Static method in interface io.pravega.client.state.Revision: Deserializes the revision from its serialized from obtained from calling Revision.toString().
fromString(String) - Static method in interface io.pravega.client.tables.Version: Deserializes the Version from its serialized form obtained from calling Version.toString().

G

generateStreamCuts(ScheduledExecutorService) - Method in interface io.pravega.client.stream.ReaderGroup: Generates a StreamCut after co-ordinating with all the readers using StateSynchronizer.
get(TableKey) - Method in interface io.pravega.client.tables.KeyValueTable: Gets the latest value for a TableKey.
getAll(Iterable<TableKey>) - Method in interface io.pravega.client.tables.KeyValueTable: Gets the latest values for a set of TableKeys.
getAutomaticCheckpointIntervalMillis() - Method in class io.pravega.client.stream.ReaderGroupConfig
getBackoffMultiple() - Method in class io.pravega.client.stream.EventWriterConfig: Backoff multiplier used in the retry logic of the writer.
getBackoffMultiple() - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration
getBufferSize() - Method in class io.pravega.client.stream.ReaderConfig
getCheckpointName() - Method in interface io.pravega.client.stream.EventRead: If a checkpoint has been requested this will return the checkpointName passed to ReaderGroup.initiateCheckpoint(String,ScheduledExecutorService) otherwise this will return null.
getConfig() - Method in interface io.pravega.client.stream.EventStreamReader: Gets the configuration that this reader was created with.
getConfig() - Method in interface io.pravega.client.stream.EventStreamWriter: Returns the configuration that this writer was create with.
getConfig() - Method in interface io.pravega.client.stream.IdempotentEventStreamWriter: Returns the configuration that this writer was create with.
getConfig() - Method in interface io.pravega.client.stream.TransactionalEventStreamWriter: Returns the configuration that this writer was created with.
getConnectTimeoutMilliSec() - Method in class io.pravega.client.ClientConfig: Maximum Connection timeout in milliseconds for establishing connections.
getControllerURI() - Method in class io.pravega.client.ClientConfig: controllerURI The controller rpc URI.
getCredentials() - Method in class io.pravega.client.ClientConfig: Credentials to be passed on to the Pravega controller for authentication and authorization.
getCurrentTimeWindow(Stream) - Method in interface io.pravega.client.stream.EventStreamReader: Returns a window which represents the range of time that this reader is currently reading as provided by writers via the EventStreamWriter.noteTime(long) API.
getDistanceBetweenTwoStreamCuts(Stream, StreamCut, StreamCut) - Method in interface io.pravega.client.admin.StreamManager: Fetch the distance between two streamCuts in bytes.
getEndingStreamCuts() - Method in class io.pravega.client.stream.ReaderGroupConfig
getEndOfDataNotifier(ScheduledExecutorService) - Method in class io.pravega.client.stream.notifications.NotifierFactory
getEndOfDataNotifier(ScheduledExecutorService) - Method in interface io.pravega.client.stream.notifications.ReaderGroupNotificationListener: Get an end of data notifier for a given reader group.
getEndOffset() - Method in interface io.pravega.client.batch.SegmentRange: Returns the end offset of the segment.
getEndStreamCut() - Method in interface io.pravega.client.batch.StreamSegmentsIterator: This returns the end StreamCut specified in BatchClientFactory.getSegments(Stream, StreamCut, StreamCut).
getEvent() - Method in interface io.pravega.client.stream.EventRead: Returns the event that is wrapped in this EventRead or null a timeout occurred or if a checkpoint was requested.
getEventPointer() - Method in interface io.pravega.client.stream.EventRead: Returns a pointer object for the event read.
getEventWriterConfig() - Method in class io.pravega.client.state.SynchronizerConfig: This writer config is used by the segment writers in the StateSynchronizer.
getGeneration() - Method in class io.pravega.client.stream.ReaderGroupConfig
getGroupName() - Method in interface io.pravega.client.stream.ReaderGroup: Returns the name of the group.
getGroupRefreshTimeMillis() - Method in class io.pravega.client.stream.ReaderGroupConfig
getHeadStreamCut() - Method in class io.pravega.client.admin.StreamInfo: StreamCut representing the current HEAD of the stream.
getHighOrder() - Method in class io.pravega.client.stream.Sequence
getInitialAllocationDelay() - Method in class io.pravega.client.stream.ReaderConfig
getInitialBackoffMillis() - Method in class io.pravega.client.stream.EventWriterConfig: Initial backoff in milli seconds used in the retry logic of the writer.
getInitialBackoffMillis() - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration
getItems() - Method in class io.pravega.client.tables.IteratorItem: A List of items that are contained in this instance.
getIterator() - Method in interface io.pravega.client.batch.StreamSegmentsIterator: This returns an iterator for SegmentRange specified in BatchClientFactory.getSegments(Stream, StreamCut, StreamCut).
getKey() - Method in class io.pravega.client.tables.TableEntry: The TableKey.
getKey() - Method in class io.pravega.client.tables.TableModification: The TableKey affected.
getKeyValueTableName() - Method in class io.pravega.client.admin.KeyValueTableInfo: Key-Value Table name.
getLowerTimeBound() - Method in class io.pravega.client.stream.TimeWindow
getLowOrder() - Method in class io.pravega.client.stream.Sequence
getMark() - Method in interface io.pravega.client.state.RevisionedStreamClient: Returns a location previously set by RevisionedStreamClient.compareAndSetMark(Revision, Revision).
getMaxBackoffMillis() - Method in class io.pravega.client.stream.EventWriterConfig: Maximum backoff in milli seconds used in the retry logic of the writer.
getMaxBackoffMillis() - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration
getMaxConnectionsPerSegmentStore() - Method in class io.pravega.client.ClientConfig: Maximum number of connections per Segment store to be used by connection pooling.
getMaxOutstandingCheckpointRequest() - Method in class io.pravega.client.stream.ReaderGroupConfig
getMetricListener() - Method in class io.pravega.client.ClientConfig: An optional listener which can be used to get performance metrics from the client.
getMetrics() - Method in interface io.pravega.client.stream.ReaderGroup: Returns metrics for this reader group.
getMinNumSegments() - Method in class io.pravega.client.stream.ScalingPolicy
getName() - Method in interface io.pravega.client.stream.Checkpoint: Returns the name of the Checkpoint specified in ReaderGroup.initiateCheckpoint(String, java.util.concurrent.ScheduledExecutorService).
getNextStreamCut(StreamCut, long) - Method in interface io.pravega.client.BatchClientFactory: Provides a streamcut approximately the requested distance after the starting streamcut.
getNumOfReaders() - Method in class io.pravega.client.stream.notifications.SegmentNotification
getNumOfSegments() - Method in class io.pravega.client.stream.notifications.SegmentNotification
getOffset() - Method in interface io.pravega.client.batch.SegmentIterator: Provides the current offset in the segment.
getOffset() - Method in class io.pravega.client.byteStream.ByteStreamReader: Returns the current byte offset in the segment.
getOnlineReaders() - Method in interface io.pravega.client.stream.ReaderGroup: Returns a set of readerIds for the readers that are considered to be online by the group.
getPartitionCount() - Method in class io.pravega.client.tables.KeyValueTableConfiguration: The number of Partitions for a Key-Value Table.
getPosition() - Method in interface io.pravega.client.stream.EventRead: The position in the stream that represents where the reader is immediately following this event.
getPrimaryKey() - Method in class io.pravega.client.tables.TableKey: The Primary Key.
getPrimaryKeyLength() - Method in class io.pravega.client.tables.KeyValueTableConfiguration: The number of bytes for the Primary Key.
getReadBufferSize() - Method in class io.pravega.client.state.SynchronizerConfig: This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment.
getReaderGroup(String) - Method in interface io.pravega.client.admin.ReaderGroupManager: Returns the requested reader group.
getReaderGroupId() - Method in class io.pravega.client.stream.ReaderGroupConfig
getReaderId() - Method in exception io.pravega.client.stream.ReaderNotInReaderGroupException
getReaderSegmentDistribution() - Method in interface io.pravega.client.stream.ReaderGroup: Returns current distribution of number of segments assigned to each reader in the reader group.
getReaderSegmentDistribution() - Method in class io.pravega.client.stream.ReaderSegmentDistribution
getRetentionMax() - Method in class io.pravega.client.stream.RetentionPolicy
getRetentionParam() - Method in class io.pravega.client.stream.RetentionPolicy
getRetentionPolicy() - Method in class io.pravega.client.stream.StreamConfiguration: API to return retention policy.
getRetentionType() - Method in class io.pravega.client.stream.ReaderGroupConfig
getRetentionType() - Method in class io.pravega.client.stream.RetentionPolicy
getRetryAttempts() - Method in class io.pravega.client.stream.EventWriterConfig: Maximum retry attempts performed by the writer before throwing a RetriesExhaustedException.
getRetryAttempts() - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration
getRevision() - Method in interface io.pravega.client.state.Revisioned: Returns the revision corresponding to this object.
getRolloverSizeBytes() - Method in class io.pravega.client.stream.StreamConfiguration: API to return segment rollover size.
getRolloverSizeBytes() - Method in class io.pravega.client.tables.KeyValueTableConfiguration: The rollover size for table segment in LTS.
getScaleFactor() - Method in class io.pravega.client.stream.ScalingPolicy
getScaleType() - Method in class io.pravega.client.stream.ScalingPolicy
getScalingPolicy() - Method in class io.pravega.client.stream.StreamConfiguration: API to return scaling policy.
getScope() - Method in class io.pravega.client.admin.KeyValueTableInfo: Scope name of the Key-Value Table.
getScope() - Method in class io.pravega.client.admin.StreamInfo: Scope name of the stream.
getScope() - Method in interface io.pravega.client.batch.SegmentRange: Returns the scope name of the stream the segment is associated with.
getScope() - Method in interface io.pravega.client.stream.ReaderGroup: Returns the scope of the stream which the group is associated with.
getScope() - Method in interface io.pravega.client.stream.Stream: Gets the scope of this stream.
getScopedName() - Method in class io.pravega.client.admin.KeyValueTableInfo: Gets a Fully Qualified Key-Value Table Name.
getScopedName() - Method in interface io.pravega.client.stream.Stream: Gets the scoped name of this stream.
getScopedStreamName() - Method in interface io.pravega.client.state.Revisioned: Returns the scoped name of this stream used to persist this object.
getSecondaryKey() - Method in class io.pravega.client.tables.TableKey: The Secondary Key (Optional).
getSecondaryKeyLength() - Method in class io.pravega.client.tables.KeyValueTableConfiguration: The number of bytes for the Secondary Key.
getSegment() - Method in interface io.pravega.client.batch.SegmentRange: Returns the segment.
getSegmentId() - Method in interface io.pravega.client.batch.SegmentRange: Returns the segment number of Segment.
getSegmentNotifier(ScheduledExecutorService) - Method in class io.pravega.client.stream.notifications.NotifierFactory
getSegmentNotifier(ScheduledExecutorService) - Method in interface io.pravega.client.stream.notifications.ReaderGroupNotificationListener: Get a segment notifier for a given reader group.
getSegmentRangeBetweenStreamCuts(StreamCut, StreamCut) - Method in interface io.pravega.client.BatchClientFactory: Provides a list of SegmentRange in between a start and end streamCut.
getSegments(Stream, StreamCut, StreamCut) - Method in interface io.pravega.client.BatchClientFactory: Provides a list of segments for a given stream between fromStreamCut and toStreamCut.
getStartingStreamCuts() - Method in class io.pravega.client.stream.ReaderGroupConfig
getStartOffset() - Method in interface io.pravega.client.batch.SegmentRange: Returns the start offset of the segment.
getStartStreamCut() - Method in interface io.pravega.client.batch.StreamSegmentsIterator: This returns the start StreamCut specified in BatchClientFactory.getSegments(Stream, StreamCut, StreamCut).
getState() - Method in interface io.pravega.client.state.StateSynchronizer: Gets the state object currently held in memory.
getStream() - Method in interface io.pravega.client.stream.EventPointer: Returns the stream from which event is read from, fully qualified stream name can be obtained from calling Stream.getScopedName()}.
getStream() - Method in interface io.pravega.client.stream.TransactionInfo: Get the stream in which transaction happens.
getStreamConfiguration() - Method in class io.pravega.client.admin.StreamInfo: Stream Configuration.
getStreamCuts() - Method in interface io.pravega.client.stream.ReaderGroup: Returns a StreamCut for each stream that this reader group is reading from.
getStreamName() - Method in class io.pravega.client.admin.StreamInfo: Stream name.
getStreamName() - Method in interface io.pravega.client.batch.SegmentRange: Returns the stream name the segment is associated with.
getStreamName() - Method in interface io.pravega.client.stream.Stream: Gets the name of this stream (Not including the scope).
getStreamNames() - Method in interface io.pravega.client.stream.ReaderGroup: Returns the set of scoped stream names which was used to configure this group.
getStreamTags(String, String) - Method in interface io.pravega.client.admin.StreamManager: Gets the Tags associated with a stream.
getTableName() - Method in exception io.pravega.client.tables.ConditionalTableUpdateException
getTags() - Method in class io.pravega.client.stream.StreamConfiguration: API to return the configured tags for the Stream.
getTailStreamCut() - Method in class io.pravega.client.admin.StreamInfo: StreamCut representing the current TAIL of the stream.
getTargetRate() - Method in class io.pravega.client.stream.ScalingPolicy
getTimestampAggregationTimeout() - Method in class io.pravega.client.stream.StreamConfiguration: The duration after the last call to EventStreamWriter.noteTime(long) until which the writer would be considered for computing EventStreamReader.getCurrentTimeWindow(Stream) Meaning that after this long of not calling EventStreamWriter.noteTime(long) a writer's previously reported time would be ignored for computing the time window.
getTotalKeyLength() - Method in class io.pravega.client.tables.KeyValueTableConfiguration: The total number of bytes for the key (includes Primary and Secondary).
getTransactionId() - Method in interface io.pravega.client.stream.TransactionInfo: Get unique transaction Id.
getTransactionStatus() - Method in interface io.pravega.client.stream.TransactionInfo: Get status of transaction.
getTransactionTimeoutTime() - Method in class io.pravega.client.stream.EventWriterConfig: The transaction timeout parameter corresponds to the lease renewal period.
getTrustStore() - Method in class io.pravega.client.ClientConfig: Path to an optional truststore.
getTxn(UUID) - Method in interface io.pravega.client.stream.TransactionalEventStreamWriter: Returns a previously created transaction.
getTxnId() - Method in interface io.pravega.client.stream.Transaction: Returns a unique ID that can be used to identify this transaction.
getType() - Method in class io.pravega.client.stream.notifications.notifier.EndOfDataNotifier
getType() - Method in class io.pravega.client.stream.notifications.notifier.SegmentNotifier
getType() - Method in interface io.pravega.client.stream.notifications.Observable: Get the notification type.
getUnassignedSegments() - Method in class io.pravega.client.stream.ReaderSegmentDistribution
getUpperTimeBound() - Method in class io.pravega.client.stream.TimeWindow
getValue() - Method in enum io.pravega.client.stream.ScalingPolicy.ScaleType
getValue() - Method in class io.pravega.client.tables.TableEntry: The Value.
getValue() - Method in class io.pravega.client.tables.TableEntryUpdate: The new value to associate the TableKey with.
getVersion() - Method in class io.pravega.client.tables.Insert
getVersion() - Method in class io.pravega.client.tables.Put
getVersion() - Method in class io.pravega.client.tables.Remove
getVersion() - Method in class io.pravega.client.tables.TableEntry: The Version
getVersion() - Method in class io.pravega.client.tables.TableModification: Gets a Version that may condition the modification.
groupRefreshTimeMillis(long) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder

H

hashCode() - Method in class io.pravega.client.admin.KeyValueTableInfo
hashCode() - Method in class io.pravega.client.admin.StreamInfo
hashCode() - Method in class io.pravega.client.ClientConfig
hashCode() - Method in class io.pravega.client.state.SynchronizerConfig
hashCode() - Method in class io.pravega.client.stream.EventWriterConfig
hashCode() - Method in class io.pravega.client.stream.notifications.Notification
hashCode() - Method in class io.pravega.client.stream.notifications.SegmentNotification
hashCode() - Method in class io.pravega.client.stream.ReaderConfig
hashCode() - Method in class io.pravega.client.stream.ReaderGroupConfig
hashCode() - Method in class io.pravega.client.stream.RetentionPolicy
hashCode() - Method in class io.pravega.client.stream.ScalingPolicy
hashCode() - Method in class io.pravega.client.stream.Sequence
hashCode() - Method in class io.pravega.client.stream.StreamConfiguration
hashCode() - Method in class io.pravega.client.stream.TimeWindow
hashCode() - Method in class io.pravega.client.tables.IteratorItem
hashCode() - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration
hashCode() - Method in class io.pravega.client.tables.KeyValueTableConfiguration
hashCode() - Method in class io.pravega.client.tables.TableEntry
hashCode() - Method in class io.pravega.client.tables.TableKey

I

IdempotentEventStreamWriter<Type> - Interface in io.pravega.client.stream: A writer can write events to a stream.
initialAllocationDelay(long) - Method in class io.pravega.client.stream.ReaderConfig.ReaderConfigBuilder
initialBackoffMillis(int) - Method in class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder: Initial backoff in milli seconds used in the retry logic of the writer.
initialBackoffMillis(int) - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration.KeyValueTableClientConfigurationBuilder
initialize(InitialUpdate<StateT>) - Method in interface io.pravega.client.state.StateSynchronizer: This method can be used to provide an initial value for a new stream if the stream has not been previously initialized.
InitialUpdate<StateT extends Revisioned> - Interface in io.pravega.client.state: A constructor for a StateT object.
initiateCheckpoint(String) - Method in interface io.pravega.client.stream.ReaderGroup: Initiate a checkpoint.
initiateCheckpoint(String, ScheduledExecutorService) - Method in interface io.pravega.client.stream.ReaderGroup: Initiate a checkpoint.
Insert - Class in io.pravega.client.tables: Represents an Insertion of a TableKey (with a value) into a KeyValueTable.
Insert(TableKey, ByteBuffer) - Constructor for class io.pravega.client.tables.Insert: Creates a new instance of the Insert class.
InvalidStreamException - Exception in io.pravega.client.stream
InvalidStreamException(String) - Constructor for exception io.pravega.client.stream.InvalidStreamException
InvalidStreamException(String, Throwable) - Constructor for exception io.pravega.client.stream.InvalidStreamException
InvalidStreamException(Throwable) - Constructor for exception io.pravega.client.stream.InvalidStreamException
io.pravega.client - package io.pravega.client
io.pravega.client.admin - package io.pravega.client.admin
io.pravega.client.batch - package io.pravega.client.batch
io.pravega.client.byteStream - package io.pravega.client.byteStream
io.pravega.client.security.auth - package io.pravega.client.security.auth
io.pravega.client.state - package io.pravega.client.state
io.pravega.client.stream - package io.pravega.client.stream
io.pravega.client.stream.notifications - package io.pravega.client.stream.notifications
io.pravega.client.stream.notifications.notifier - package io.pravega.client.stream.notifications.notifier
io.pravega.client.tables - package io.pravega.client.tables
io.pravega.client.watermark - package io.pravega.client.watermark
isAutomaticallyNoteTime() - Method in class io.pravega.client.stream.EventWriterConfig: Automatically invoke EventStreamWriter.noteTime(long) passing System.currentTimeMillis() on a regular interval.
isCheckpoint() - Method in interface io.pravega.client.stream.EventRead: A boolean indicating if this is a checkpoint.
isDefaultMaxConnections(boolean) - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder: An internal property that determines if the client config.
isDisableTimeWindows() - Method in class io.pravega.client.stream.ReaderConfig
isEnableConnectionPooling() - Method in class io.pravega.client.stream.EventWriterConfig: Enable or disable connection pooling for writer.
isEnableLargeEvents() - Method in class io.pravega.client.stream.EventWriterConfig: Enable or disable whether LargeEvent writes should be processed and sent to the SegmentStore.
isEnableTls() - Method in class io.pravega.client.ClientConfig: Returns whether TLS is enabled for client-to-server (Controller and Segment Store) communications.
isEnableTlsToController() - Method in class io.pravega.client.ClientConfig
isEnableTlsToSegmentStore() - Method in class io.pravega.client.ClientConfig
isListenerPresent(String) - Method in class io.pravega.client.stream.notifications.NotificationSystem: Check if a Listener is present for a given notification type.
isNearHeadOfStream() - Method in class io.pravega.client.stream.TimeWindow: Returns true if the reader is currently near the head of the stream and therefore no lower time bound can be obtained.
isNearTailOfStream() - Method in class io.pravega.client.stream.TimeWindow: Returns true if the reader is currently near the tail of the stream and therefore no upper time bound can be obtained.
isReadCompleted() - Method in interface io.pravega.client.stream.EventRead: A boolean indicating if all events in the stream read completely.
isRemoval() - Method in class io.pravega.client.tables.Remove
isRemoval() - Method in class io.pravega.client.tables.TableEntryUpdate
isRemoval() - Method in class io.pravega.client.tables.TableModification: Gets a value indicating whether this modification attempts to remove the TableKey or not.
isSealed() - Method in class io.pravega.client.admin.StreamInfo: Indicates whether the Stream is sealed (true) or not (false).
isTagOnlyChange(StreamConfiguration, StreamConfiguration) - Static method in class io.pravega.client.stream.StreamConfiguration: Check if only the tags have been modified between the two StreamConfigurations.
isValidateHostName() - Method in class io.pravega.client.ClientConfig: If the flag ClientConfig.isEnableTls() is set, this flag decides whether to enable host name validation or not.
iterator() - Method in interface io.pravega.client.tables.KeyValueTable: Creates a new KeyValueTableIterator.Builder that can be used to construct and execute an Iterator over the TableKey/TableEntry instances in this KeyValueTable.
IteratorItem<T> - Class in io.pravega.client.tables: An iteration result item returned by AsyncIterator when invoking KeyValueTable.iterator().
IteratorItem(List<T>) - Constructor for class io.pravega.client.tables.IteratorItem

J

JwtTokenProviderImpl - Class in io.pravega.client.security.auth: Provides JWT-based delegation tokens.

K

keys() - Method in interface io.pravega.client.tables.KeyValueTableIterator: Creates a new Iterator for TableKeys in the associated KeyValueTable.
KeyValueTable - Interface in io.pravega.client.tables: Defines all operations that are supported on a Key-Value Table.
KeyValueTableClientConfiguration - Class in io.pravega.client.tables: Configuration for the KeyValueTable client.
KeyValueTableClientConfiguration.KeyValueTableClientConfigurationBuilder - Class in io.pravega.client.tables
KeyValueTableConfiguration - Class in io.pravega.client.tables: The configuration of a Key-Value Table.
KeyValueTableConfiguration.KeyValueTableConfigurationBuilder - Class in io.pravega.client.tables
KeyValueTableFactory - Interface in io.pravega.client: Creates instances of KeyValueTable.
KeyValueTableInfo - Class in io.pravega.client.admin: Information about a Key-Value Table.
KeyValueTableInfo(String, String) - Constructor for class io.pravega.client.admin.KeyValueTableInfo
KeyValueTableIterator - Interface in io.pravega.client.tables: Defines a preconfigured Iterator for a KeyValueTable, which can be used to iterate over TableKey or TableEntry instances.
KeyValueTableIterator.Builder - Interface in io.pravega.client.tables: Defines a Builder for a KeyValueTableIterator.
KeyValueTableManager - Interface in io.pravega.client.admin: Used to create, delete and manage Key-Value Tables.
KeyVersion - Class in io.pravega.client.tables: Version of a Key in a Table.

L

listCompletedTransactions(Stream) - Method in interface io.pravega.client.admin.StreamManager: List most recent completed (COMMITTED/ABORTED) transactions.
Listener<T> - Interface in io.pravega.client.stream.notifications: Listener interface for receiving notifications.
listKeyValueTables(String) - Method in interface io.pravega.client.admin.KeyValueTableManager: Gets an iterator for all Key-Value Table in the given scope.
listScopes() - Method in interface io.pravega.client.admin.StreamManager: Gets an iterator for all scopes.
listStreams(String) - Method in interface io.pravega.client.admin.StreamManager: Gets an iterator for all streams in scope.
listStreams(String, String) - Method in interface io.pravega.client.admin.StreamManager: Gets an iterator to list all streams with the provided tag.

M

MANUAL_RELEASE_AT_USER_STREAMCUT - io.pravega.client.stream.ReaderGroupConfig.StreamDataRetention
MAX_EVENT_SIZE - Static variable in interface io.pravega.client.stream.Serializer: The maximum event size, in bytes.
MAX_VALUE - Static variable in class io.pravega.client.stream.Sequence
maxBackoffMillis(int) - Method in class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder: Maximum backoff in milli seconds used in the retry logic of the writer.
maxBackoffMillis(int) - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration.KeyValueTableClientConfigurationBuilder
maxConnectionsPerSegmentStore(int) - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder
MAXIMUM_VALUE_LENGTH - Static variable in interface io.pravega.client.tables.KeyValueTable: The maximum length of a Table Segment Value.
maxIterationSize(int) - Method in interface io.pravega.client.tables.KeyValueTableIterator.Builder: Sets the maximum number of items to return with each call to AsyncIterator.getNext().
maxOutstandingCheckpointRequest(int) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder
metricListener(MetricListener) - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder: An optional listener which can be used to get performance metrics from the client.
MIN_VALUE - Static variable in class io.pravega.client.stream.Sequence
minNumSegments(int) - Method in class io.pravega.client.stream.ScalingPolicy.ScalingPolicyBuilder

N

NO_VERSION - Static variable in class io.pravega.client.tables.KeyVersion: KeyVersion that indicates no specific version is desired.
NO_VERSION - Static variable in interface io.pravega.client.tables.Version: Version that indicates no specific version is desired.
NONE - io.pravega.client.stream.ReaderGroupConfig.StreamDataRetention
NoSuchKeyException - Exception in io.pravega.client.tables: Exception that is thrown whenever a conditional KeyValueTable update failed due to the key not existing.
NoSuchKeyException(String) - Constructor for exception io.pravega.client.tables.NoSuchKeyException: Creates a new instance of the NoSuchKeyException class.
NoSuchScopeException - Exception in io.pravega.client.stream
NoSuchScopeException() - Constructor for exception io.pravega.client.stream.NoSuchScopeException: Creates a new instance of NoSuchScopeException class.
NOT_EXISTS - Static variable in class io.pravega.client.tables.KeyVersion: KeyVersion that indicates the TableKey must not exist.
NOT_EXISTS - Static variable in interface io.pravega.client.tables.Version: Version that indicates the TableKey must not exist.
noteTime(long) - Method in interface io.pravega.client.stream.EventStreamWriter: Notes a time that can be seen by readers which read from this stream by EventStreamReader.getCurrentTimeWindow(Stream).
Notification - Class in io.pravega.client.stream.notifications: Represents base notification type.
Notification() - Constructor for class io.pravega.client.stream.notifications.Notification
NotificationSystem - Class in io.pravega.client.stream.notifications
NotificationSystem() - Constructor for class io.pravega.client.stream.notifications.NotificationSystem
NotifierFactory - Class in io.pravega.client.stream.notifications: Factory used to create different types of notifiers.
NotifierFactory(NotificationSystem, StateSynchronizer<ReaderGroupState>) - Constructor for class io.pravega.client.stream.notifications.NotifierFactory
notify(T) - Method in class io.pravega.client.stream.notifications.NotificationSystem: This method will ensure the notification is intimated to the listeners of the same type.
notifySystem - Variable in class io.pravega.client.stream.notifications.notifier.AbstractNotifier
numOfReaders(int) - Method in class io.pravega.client.stream.notifications.SegmentNotification.SegmentNotificationBuilder
numOfSegments(int) - Method in class io.pravega.client.stream.notifications.SegmentNotification.SegmentNotificationBuilder

O

Observable<T> - Interface in io.pravega.client.stream.notifications: This represents an observable notification.
of(String) - Static method in interface io.pravega.client.stream.Stream: Helper utility to create a Stream object from a scopedName of a Stream.
of(String, String) - Static method in interface io.pravega.client.stream.Stream: Helper utility to create a Stream object.
onDataAvailable() - Method in class io.pravega.client.byteStream.ByteStreamReader: Returns a future that will be completed when there is data available to be read.
onNotification(T) - Method in interface io.pravega.client.stream.notifications.Listener
OPEN - io.pravega.client.stream.Transaction.PingStatus
OPEN - io.pravega.client.stream.Transaction.Status

P

partitionCount(int) - Method in class io.pravega.client.tables.KeyValueTableConfiguration.KeyValueTableConfigurationBuilder: The number of Partitions for a Key-Value Table.
PingFailedException - Exception in io.pravega.client.stream: Transaction heartbeat to a controller instance failed, because of one of the following reasons.
PingFailedException() - Constructor for exception io.pravega.client.stream.PingFailedException
PingFailedException(String) - Constructor for exception io.pravega.client.stream.PingFailedException
PingFailedException(String, Throwable) - Constructor for exception io.pravega.client.stream.PingFailedException
PingFailedException(Throwable) - Constructor for exception io.pravega.client.stream.PingFailedException
pollNow() - Method in class io.pravega.client.stream.notifications.notifier.EndOfDataNotifier: Invokes the periodic processing now in the current thread.
pollNow() - Method in class io.pravega.client.stream.notifications.notifier.SegmentNotifier: Invokes the periodic processing now in the current thread.
populateToken(String) - Method in interface io.pravega.client.security.auth.DelegationTokenProvider: Populates the object with the specified delegation token.
populateToken(String) - Method in class io.pravega.client.security.auth.EmptyTokenProviderImpl
populateToken(String) - Method in class io.pravega.client.security.auth.JwtTokenProviderImpl
populateToken(String) - Method in class io.pravega.client.security.auth.StringTokenProviderImpl
Position - Interface in io.pravega.client.stream: A position in a stream.
primaryKeyLength(int) - Method in class io.pravega.client.tables.KeyValueTableConfiguration.KeyValueTableConfigurationBuilder: The number of bytes for the Primary Key.
Put - Class in io.pravega.client.tables: Updates the Value associated with a TableKey in a KeyValueTable.
Put(TableKey, ByteBuffer) - Constructor for class io.pravega.client.tables.Put: Creates a new instance of the Put class for an unconditional update.
Put(TableKey, ByteBuffer, Version) - Constructor for class io.pravega.client.tables.Put: Creates a new instance of the Put class for a conditional update.

R

read() - Method in class io.pravega.client.byteStream.ByteStreamReader: Reads a single byte.
read(byte[]) - Method in class io.pravega.client.byteStream.ByteStreamReader: This is equivalent to calling read(b, 0, b.length) Will only block if ByteStreamReader.available() is 0.
read(byte[], int, int) - Method in class io.pravega.client.byteStream.ByteStreamReader: If ByteStreamReader.available() is non-zero, this method will read bytes from an in-memory buffer into the provided array.
read(ByteBuffer) - Method in class io.pravega.client.byteStream.ByteStreamReader: Similar to ByteStreamReader.read(byte[], int, int) but takes a byteBuffer.
readBufferSize(int) - Method in class io.pravega.client.state.SynchronizerConfig.SynchronizerConfigBuilder: This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment.
ReaderConfig - Class in io.pravega.client.stream
ReaderConfig.ReaderConfigBuilder - Class in io.pravega.client.stream
ReaderGroup - Interface in io.pravega.client.stream: A reader group is a collection of readers that collectively read all the events in the stream.
ReaderGroupConfig - Class in io.pravega.client.stream
ReaderGroupConfig.ReaderGroupConfigBuilder - Class in io.pravega.client.stream
ReaderGroupConfig.StreamDataRetention - Enum in io.pravega.client.stream: 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 - Interface in io.pravega.client.admin: Used to create and manage reader groups.
ReaderGroupMetrics - Interface in io.pravega.client.stream
ReaderGroupNotFoundException - Exception in io.pravega.client.stream: ReaderGroupNotFoundException is thrown by ReaderGroupManager.getReaderGroup(String) API when the provided reader group does not exist.
ReaderGroupNotFoundException(String) - Constructor for exception io.pravega.client.stream.ReaderGroupNotFoundException
ReaderGroupNotFoundException(String, Throwable) - Constructor for exception io.pravega.client.stream.ReaderGroupNotFoundException
ReaderGroupNotificationListener - Interface in io.pravega.client.stream.notifications: ReaderGroup notification listener interface.
ReaderNotInReaderGroupException - Exception in io.pravega.client.stream: Read was invoked on a reader that the reader group does not consider a member.
ReaderNotInReaderGroupException(String) - Constructor for exception io.pravega.client.stream.ReaderNotInReaderGroupException
readerOffline(String, Position) - Method in interface io.pravega.client.stream.ReaderGroup: Invoked when a reader that was added to the group is no longer consuming events.
readerSegmentDistribution(Map<String, Integer>) - Method in class io.pravega.client.stream.ReaderSegmentDistribution.ReaderSegmentDistributionBuilder
ReaderSegmentDistribution - Class in io.pravega.client.stream: Describes current distribution of number of segments assigned to each reader in the reader group.
ReaderSegmentDistribution.ReaderSegmentDistributionBuilder - Class in io.pravega.client.stream
readFrom(Revision) - Method in interface io.pravega.client.state.RevisionedStreamClient: Read all data after a specified revision to the end of the stream.
readNextEvent(long) - Method in interface io.pravega.client.stream.EventStreamReader: Gets the next event in the stream.
readRange(Revision, Revision) - Method in interface io.pravega.client.state.RevisionedStreamClient: Read all data from a given start revision to a given end revision.
readSegment(SegmentRange, Serializer<T>) - Method in interface io.pravega.client.BatchClientFactory: Provides a SegmentIterator to read the events in the requested segment starting from the beginning of the segment and ending at the current end of the segment.
registerListener(Listener<EndOfDataNotification>) - Method in class io.pravega.client.stream.notifications.notifier.EndOfDataNotifier
registerListener(Listener<SegmentNotification>) - Method in class io.pravega.client.stream.notifications.notifier.SegmentNotifier
registerListener(Listener<T>) - Method in class io.pravega.client.stream.notifications.notifier.AbstractNotifier
registerListener(Listener<T>) - Method in interface io.pravega.client.stream.notifications.Observable: Register listener for notification type T.
ReinitializationRequiredException - Exception in io.pravega.client.stream: ReinitializationRequiredException is thrown by EventStreamReader.readNextEvent(long) API if ReaderGroup.resetReaderGroup(ReaderGroupConfig) was called, which requires readers to be reinitialized.
ReinitializationRequiredException() - Constructor for exception io.pravega.client.stream.ReinitializationRequiredException
ReinitializationRequiredException(String) - Constructor for exception io.pravega.client.stream.ReinitializationRequiredException
ReinitializationRequiredException(String, Throwable) - Constructor for exception io.pravega.client.stream.ReinitializationRequiredException
ReinitializationRequiredException(Throwable) - Constructor for exception io.pravega.client.stream.ReinitializationRequiredException
Remove - Class in io.pravega.client.tables: Removes a TableKey from a KeyValueTable.
Remove(TableKey) - Constructor for class io.pravega.client.tables.Remove: Creates a new instance of the Remove class for an unconditional removal.
Remove(TableKey, Version) - Constructor for class io.pravega.client.tables.Remove: Creates a new instance of the Remove class for a conditional removal.
removeListener(String, Listener<T>) - Method in class io.pravega.client.stream.notifications.NotificationSystem: Remove Listener of a given notification type.
removeListeners(String) - Method in class io.pravega.client.stream.notifications.NotificationSystem: Remove all listeners of a notification type.
resetReaderGroup() - Method in interface io.pravega.client.stream.ReaderGroup: Reset a reader group to successfully completed last checkpoint.
resetReaderGroup(ReaderGroupConfig) - Method in interface io.pravega.client.stream.ReaderGroup: Reset a reader group with the provided ReaderGroupConfig.
retentionMax(long) - Method in class io.pravega.client.stream.RetentionPolicy.RetentionPolicyBuilder
retentionParam(long) - Method in class io.pravega.client.stream.RetentionPolicy.RetentionPolicyBuilder
retentionPolicy(RetentionPolicy) - Method in class io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder: API to return retention policy.
RetentionPolicy - Class in io.pravega.client.stream
RetentionPolicy.RetentionPolicyBuilder - Class in io.pravega.client.stream
RetentionPolicy.RetentionType - Enum in io.pravega.client.stream
retentionType(ReaderGroupConfig.StreamDataRetention) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder: Set the retention config for the ReaderGroup.
retentionType(RetentionPolicy.RetentionType) - Method in class io.pravega.client.stream.RetentionPolicy.RetentionPolicyBuilder
retrieveToken() - Method in interface io.pravega.client.security.auth.DelegationTokenProvider: Retrieve delegation token.
retrieveToken() - Method in class io.pravega.client.security.auth.EmptyTokenProviderImpl
retrieveToken() - Method in class io.pravega.client.security.auth.JwtTokenProviderImpl: Returns the delegation token.
retrieveToken() - Method in class io.pravega.client.security.auth.StringTokenProviderImpl
retryAttempts(int) - Method in class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder: Maximum retry attempts performed by the writer before throwing a RetriesExhaustedException.
retryAttempts(int) - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration.KeyValueTableClientConfigurationBuilder
Revision - Interface in io.pravega.client.state: A maker for a version of a Revisioned object.
Revisioned - Interface in io.pravega.client.state: An object that has a revision associated with it.
RevisionedStreamClient<T> - Interface in io.pravega.client.state: Provides a stream that can be read and written to with strong consistency.
rolloverSizeBytes(long) - Method in class io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder: API to return segment rollover size.
rolloverSizeBytes(long) - Method in class io.pravega.client.tables.KeyValueTableConfiguration.KeyValueTableConfigurationBuilder: The rollover size for table segment in LTS.

S

scaleFactor(int) - Method in class io.pravega.client.stream.ScalingPolicy.ScalingPolicyBuilder
scaleType(ScalingPolicy.ScaleType) - Method in class io.pravega.client.stream.ScalingPolicy.ScalingPolicyBuilder
scalingPolicy(ScalingPolicy) - Method in class io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder: API to return scaling policy.
ScalingPolicy - Class in io.pravega.client.stream: A policy that specifies how the number of segments in a stream should scale over time.
ScalingPolicy.ScaleType - Enum in io.pravega.client.stream
ScalingPolicy.ScalingPolicyBuilder - Class in io.pravega.client.stream
sealStream(String, String) - Method in interface io.pravega.client.admin.StreamManager: Seal an existing stream.
secondaryKeyLength(int) - Method in class io.pravega.client.tables.KeyValueTableConfiguration.KeyValueTableConfigurationBuilder: The number of bytes for the Secondary Key.
seekToOffset(long) - Method in class io.pravega.client.byteStream.ByteStreamReader: Seeks to the provided offset (It can be anywhere in the segment).
SegmentIterator<T> - Interface in io.pravega.client.batch: Please note this is an experimental API.
SegmentNotification - Class in io.pravega.client.stream.notifications: Class to represent a segment notification.
SegmentNotification.SegmentNotificationBuilder - Class in io.pravega.client.stream.notifications
SegmentNotifier - Class in io.pravega.client.stream.notifications.notifier
SegmentNotifier(NotificationSystem, StateSynchronizer<ReaderGroupState>, ScheduledExecutorService) - Constructor for class io.pravega.client.stream.notifications.notifier.SegmentNotifier
SegmentRange - Interface in io.pravega.client.batch: This is used to represent range bounded portion of a Segment.
Sequence - Class in io.pravega.client.stream: A wrapper for two numbers.
serialize(Watermark) - Method in class io.pravega.client.watermark.WatermarkSerializer
serialize(T) - Method in interface io.pravega.client.stream.Serializer: Serializes the given event.
Serializer<T> - Interface in io.pravega.client.stream: 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.
setEventWriterConfig(EventWriterConfig) - Method in class io.pravega.client.state.SynchronizerConfig: This writer config is used by the segment writers in the StateSynchronizer.
setNumOfReaders(int) - Method in class io.pravega.client.stream.notifications.SegmentNotification
setNumOfSegments(int) - Method in class io.pravega.client.stream.notifications.SegmentNotification
setReadBufferSize(int) - Method in class io.pravega.client.state.SynchronizerConfig: This size is used to allocate buffer space for the bytes the reader in the StateSynchronizer reads from the segment.
signalTokenExpired() - Method in interface io.pravega.client.security.auth.DelegationTokenProvider: Signals the object that the token it may be holding has expired.
signalTokenExpired() - Method in class io.pravega.client.security.auth.EmptyTokenProviderImpl
signalTokenExpired() - Method in class io.pravega.client.security.auth.JwtTokenProviderImpl
signalTokenExpired() - Method in class io.pravega.client.security.auth.StringTokenProviderImpl
SIZE - io.pravega.client.stream.RetentionPolicy.RetentionType: Set retention based on the total size of the data in the stream in bytes.
skip(long) - Method in class io.pravega.client.byteStream.ByteStreamReader: This method attempts to skip forward by the provided number of bytes.
startFromCheckpoint(Checkpoint) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder: Ensure the readers of the ReaderGroup start from the provided Checkpoint.
startFromStreamCuts(Map<Stream, StreamCut>) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder: Ensure the readers of the ReaderGroup start from this provided streamCuts.
startingStreamCuts(Map<Stream, StreamCut>) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder
StateSynchronizer<StateT extends Revisioned> - Interface in io.pravega.client.state: Provides a means to have state that is synchronized between many processes.
StateSynchronizer.UpdateGenerator<StateT extends Revisioned> - Interface in io.pravega.client.state: A function which given a state object populates a list of updates that should be applied.
StateSynchronizer.UpdateGeneratorFunction<StateT extends Revisioned,ReturnT> - Interface in io.pravega.client.state: Similar to StateSynchronizer.UpdateGenerator but it also returns a result for the caller.
stream(Stream) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder: Add a stream that needs to be read by the readers of a ReaderGroup.
stream(Stream, StreamCut) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder: Add a stream and its associated start StreamCut to be read by the readers of a ReaderGroup.
stream(Stream, StreamCut, StreamCut) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder: Add a stream and its associated start StreamCut and end StreamCut to be read by the readers of a ReaderGroup.
stream(String) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder: Add a stream that needs to be read by the readers of a ReaderGroup.
stream(String, StreamCut) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder: Add a stream and its associated start StreamCut to be read by the readers of a ReaderGroup.
stream(String, StreamCut, StreamCut) - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder: Add a stream and its associated start StreamCut and end StreamCut to be read by the readers of a ReaderGroup.
Stream - Interface in io.pravega.client.stream: A stream can be thought of as an unbounded sequence of events.
StreamConfiguration - Class in io.pravega.client.stream: The configuration of a Stream.
StreamConfiguration.StreamConfigurationBuilder - Class in io.pravega.client.stream
StreamCut - Interface in io.pravega.client.stream: A set of segment/offset pairs for a single stream that represent a consistent position in the stream.
StreamInfo - Class in io.pravega.client.admin: This class is used to represent Stream information.
StreamInfo(String, String, StreamConfiguration, StreamCut, StreamCut, boolean) - Constructor for class io.pravega.client.admin.StreamInfo
StreamManager - Interface in io.pravega.client.admin: Used to create, delete, and manage Streams and ReaderGroups.
StreamSegmentsIterator - Interface in io.pravega.client.batch
StringTokenProviderImpl - Class in io.pravega.client.security.auth: A provider for handling non-JWT, non-empty delegation tokens.
SynchronizerClientFactory - Interface in io.pravega.client: Used to create StateSynchronizer and RevisionedStreamClient objects which allow for reading and writing data from a pre-configured stream with strong consistency guarantees.
SynchronizerConfig - Class in io.pravega.client.state: The configuration for a Consistent replicated state synchronizer.
SynchronizerConfig.SynchronizerConfigBuilder - Class in io.pravega.client.state

T

TableEntry - Class in io.pravega.client.tables: A KeyValueTable Entry.
TableEntry(TableKey, Version, ByteBuffer) - Constructor for class io.pravega.client.tables.TableEntry
TableEntryUpdate - Class in io.pravega.client.tables: Defines a TableModification that updates a TableKey with a new value.
TableKey - Class in io.pravega.client.tables: A KeyValueTable Key.
TableKey(ByteBuffer, ByteBuffer) - Constructor for class io.pravega.client.tables.TableKey
TableKey(ByteBuffer) - Constructor for class io.pravega.client.tables.TableKey
TableModification - Class in io.pravega.client.tables: Defines a modification that can be applied to a TableKey in a KeyValueTable.
tag(String) - Method in class io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder
tags(Collection<? extends String>) - Method in class io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder
targetRate(int) - Method in class io.pravega.client.stream.ScalingPolicy.ScalingPolicyBuilder
TIME - io.pravega.client.stream.RetentionPolicy.RetentionType: Set retention based on how long data has been in the stream in milliseconds.
timestampAggregationTimeout(long) - Method in class io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder: The duration after the last call to EventStreamWriter.noteTime(long) until which the writer would be considered for computing EventStreamReader.getCurrentTimeWindow(Stream) Meaning that after this long of not calling EventStreamWriter.noteTime(long) a writer's previously reported time would be ignored for computing the time window.
TimeWindow - Class in io.pravega.client.stream: Represents a time window for the events which are currently being read by a reader.
TimeWindow(Long, Long) - Constructor for class io.pravega.client.stream.TimeWindow
toBuilder() - Method in class io.pravega.client.ClientConfig
toBuilder() - Method in class io.pravega.client.stream.ReaderGroupConfig
toBuilder() - Method in class io.pravega.client.stream.StreamConfiguration
toBytes() - Method in class io.pravega.client.state.SynchronizerConfig
toBytes() - Method in interface io.pravega.client.stream.Checkpoint: Serializes the checkpoint to a compact byte array.
toBytes() - Method in interface io.pravega.client.stream.EventPointer: Serializes the Event pointer to a compact binary form.
toBytes() - Method in class io.pravega.client.stream.EventWriterConfig
toBytes() - Method in interface io.pravega.client.stream.Position: Serializes the position to a compact byte array.
toBytes() - Method in class io.pravega.client.stream.ReaderGroupConfig
toBytes() - Method in interface io.pravega.client.stream.StreamCut: Serializes the cut to a compact byte array.
toString() - Method in class io.pravega.client.admin.KeyValueTableInfo
toString() - Method in class io.pravega.client.admin.StreamInfo
toString() - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder
toString() - Method in class io.pravega.client.ClientConfig
toString() - Method in interface io.pravega.client.state.Revision: Serializes the Revision to a human readable string.
toString() - Method in class io.pravega.client.state.SynchronizerConfig.SynchronizerConfigBuilder
toString() - Method in class io.pravega.client.state.SynchronizerConfig
toString() - Method in class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder
toString() - Method in class io.pravega.client.stream.EventWriterConfig
toString() - Method in class io.pravega.client.stream.notifications.Notification
toString() - Method in class io.pravega.client.stream.notifications.SegmentNotification.SegmentNotificationBuilder
toString() - Method in class io.pravega.client.stream.notifications.SegmentNotification
toString() - Method in class io.pravega.client.stream.ReaderConfig.ReaderConfigBuilder
toString() - Method in class io.pravega.client.stream.ReaderConfig
toString() - Method in class io.pravega.client.stream.ReaderGroupConfig.ReaderGroupConfigBuilder
toString() - Method in class io.pravega.client.stream.ReaderGroupConfig
toString() - Method in class io.pravega.client.stream.ReaderSegmentDistribution.ReaderSegmentDistributionBuilder
toString() - Method in class io.pravega.client.stream.RetentionPolicy.RetentionPolicyBuilder
toString() - Method in class io.pravega.client.stream.RetentionPolicy
toString() - Method in class io.pravega.client.stream.ScalingPolicy.ScalingPolicyBuilder
toString() - Method in class io.pravega.client.stream.ScalingPolicy
toString() - Method in class io.pravega.client.stream.Sequence
toString() - Method in class io.pravega.client.stream.StreamConfiguration.StreamConfigurationBuilder
toString() - Method in class io.pravega.client.stream.StreamConfiguration
toString() - Method in class io.pravega.client.stream.TimeWindow
toString() - Method in class io.pravega.client.tables.Insert
toString() - Method in class io.pravega.client.tables.IteratorItem
toString() - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration.KeyValueTableClientConfigurationBuilder
toString() - Method in class io.pravega.client.tables.KeyValueTableClientConfiguration
toString() - Method in class io.pravega.client.tables.KeyValueTableConfiguration.KeyValueTableConfigurationBuilder
toString() - Method in class io.pravega.client.tables.KeyValueTableConfiguration
toString() - Method in class io.pravega.client.tables.Put
toString() - Method in class io.pravega.client.tables.Remove
toString() - Method in class io.pravega.client.tables.TableEntry
toString() - Method in class io.pravega.client.tables.TableKey
toString() - Method in interface io.pravega.client.tables.Version: Serializes the Version to a human readable string.
Transaction<Type> - Interface in io.pravega.client.stream: Provides a mechanism for writing many events atomically.
Transaction.PingStatus - Enum in io.pravega.client.stream
Transaction.Status - Enum in io.pravega.client.stream
TransactionalEventStreamWriter<Type> - Interface in io.pravega.client.stream: A writer that writes Events to an Event stream transactionally.
TransactionInfo - Interface in io.pravega.client.stream: TransactionInfo holds the information of transaction.
transactionTimeoutTime(long) - Method in class io.pravega.client.stream.EventWriterConfig.EventWriterConfigBuilder: The transaction timeout parameter corresponds to the lease renewal period.
truncateDataBefore(long) - Method in class io.pravega.client.byteStream.ByteStreamWriter: This makes a synchronous RPC call to the server to truncate the segment at the provided offset.
TruncatedDataException - Exception in io.pravega.client.stream: TruncatedDataException is thrown if the data to be read next has been truncated away and can no longer be read.
TruncatedDataException() - Constructor for exception io.pravega.client.stream.TruncatedDataException: Creates a new instance of TruncatedDataException class.
TruncatedDataException(String) - Constructor for exception io.pravega.client.stream.TruncatedDataException: Creates a new instance of TruncatedDataException class.
TruncatedDataException(String, Throwable) - Constructor for exception io.pravega.client.stream.TruncatedDataException: Creates a new instance of TruncatedDataException class.
TruncatedDataException(Throwable) - Constructor for exception io.pravega.client.stream.TruncatedDataException: Creates a new instance of TruncatedDataException class.
truncateStream(String, String, StreamCut) - Method in interface io.pravega.client.admin.StreamManager: Truncate stream at given stream cut.
truncateToRevision(Revision) - Method in interface io.pravega.client.state.RevisionedStreamClient: Removes all data through the revision provided.
trustStore(String) - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder: Path to an optional truststore.
TxnFailedException - Exception in io.pravega.client.stream: A transaction has failed.
TxnFailedException() - Constructor for exception io.pravega.client.stream.TxnFailedException: Creates a new instance of TxnFailedException class.
TxnFailedException(String) - Constructor for exception io.pravega.client.stream.TxnFailedException: Creates a new instance of TxnFailedException class.
TxnFailedException(String, Throwable) - Constructor for exception io.pravega.client.stream.TxnFailedException: Creates a new instance of TxnFailedException class.
TxnFailedException(Throwable) - Constructor for exception io.pravega.client.stream.TxnFailedException: Creates a new instance of TxnFailedException class.

U

unassignedSegments(int) - Method in class io.pravega.client.stream.ReaderSegmentDistribution.ReaderSegmentDistributionBuilder
UNBOUNDED - Static variable in interface io.pravega.client.stream.StreamCut: This is used represents an unbounded StreamCut.
unreadBytes() - Method in interface io.pravega.client.stream.ReaderGroupMetrics: Returns the number of bytes between the last recorded position of the readers in the ReaderGroup and the end of the stream(s).
unregisterAllListeners() - Method in class io.pravega.client.stream.notifications.notifier.AbstractNotifier
unregisterAllListeners() - Method in class io.pravega.client.stream.notifications.notifier.AbstractPollingNotifier
unregisterAllListeners() - Method in interface io.pravega.client.stream.notifications.Observable: Remove all listeners for a given type.
unregisterListener(Listener<T>) - Method in class io.pravega.client.stream.notifications.notifier.AbstractNotifier
unregisterListener(Listener<T>) - Method in class io.pravega.client.stream.notifications.notifier.AbstractPollingNotifier
unregisterListener(Listener<T>) - Method in interface io.pravega.client.stream.notifications.Observable: Remove a listener.
update(TableModification) - Method in interface io.pravega.client.tables.KeyValueTable: Performs a specific TableModification to the KeyValueTable, as described below: If update is a Insert, this will be interpreted as a Conditional Insert, so the TableEntryUpdate.getValue() will only be inserted (and associated with TableModification.getKey() if there doesn't already exist a TableKey in the KeyValueTable that matches TableModification.getKey().
update(Iterable<TableModification>) - Method in interface io.pravega.client.tables.KeyValueTable: Performs a batch of TableModifications to the KeyValueTable for TableKeys that have the same TableKey.getPrimaryKey().
Update<StateT extends Revisioned> - Interface in io.pravega.client.state: An update to a StateT object coordinated via a StateSynchronizer.
updateRetentionStreamCut(Map<Stream, StreamCut>) - Method in interface io.pravega.client.stream.ReaderGroup: Update Retention Stream-Cut for Streams in this Reader Group.
updateState(StateSynchronizer.UpdateGenerator<StateT>) - Method in interface io.pravega.client.state.StateSynchronizer: Creates a new update for the latest state object and applies it atomically.
updateState(StateSynchronizer.UpdateGeneratorFunction<StateT, ReturnT>) - Method in interface io.pravega.client.state.StateSynchronizer: Similar to StateSynchronizer.updateState(UpdateGenerator) but this version returns a result object supplied by the StateSynchronizer.UpdateGeneratorFunction.
updateStateUnconditionally(Update<StateT>) - Method in interface io.pravega.client.state.StateSynchronizer: Persists the provided update.
updateStateUnconditionally(List<? extends Update<StateT>>) - Method in interface io.pravega.client.state.StateSynchronizer: Same as StateSynchronizer.updateStateUnconditionally(Update), except it persists multiple updates at the same time so they will not be interleaved with other updates.
updateStream(String, String, StreamConfiguration) - Method in interface io.pravega.client.admin.StreamManager: Change the configuration for an existing stream.

V

validateHostName(boolean) - Method in class io.pravega.client.ClientConfig.ClientConfigBuilder: If the flag ClientConfig.isEnableTls() is set, this flag decides whether to enable host name validation or not.
valueOf(String) - Static method in enum io.pravega.client.stream.ReaderGroupConfig.StreamDataRetention: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.pravega.client.stream.RetentionPolicy.RetentionType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.pravega.client.stream.ScalingPolicy.ScaleType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.pravega.client.stream.Transaction.PingStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.pravega.client.stream.Transaction.Status: Returns the enum constant of this type with the specified name.
values() - Static method in enum io.pravega.client.stream.ReaderGroupConfig.StreamDataRetention: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.pravega.client.stream.RetentionPolicy.RetentionType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.pravega.client.stream.ScalingPolicy.ScaleType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.pravega.client.stream.Transaction.PingStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.pravega.client.stream.Transaction.Status: Returns an array containing the constants of this enum type, in the order they are declared.
Version - Interface in io.pravega.client.tables: Version of a Key in a Table.

W

WatermarkSerializer - Class in io.pravega.client.watermark
WatermarkSerializer() - Constructor for class io.pravega.client.watermark.WatermarkSerializer
withScope(String, ClientConfig) - Static method in interface io.pravega.client.admin.ReaderGroupManager: Creates a new instance of ReaderGroupManager.
withScope(String, ClientConfig) - Static method in interface io.pravega.client.BatchClientFactory: Creates a new instance of BatchClientFactory.
withScope(String, ClientConfig) - Static method in interface io.pravega.client.ByteStreamClientFactory: Creates a new instance of ByteStreamClientFactory.
withScope(String, ClientConfig) - Static method in interface io.pravega.client.EventStreamClientFactory: Creates a new instance of Client Factory.
withScope(String, ClientConfig) - Static method in interface io.pravega.client.KeyValueTableFactory: Creates a new instance of KeyValueTableFactory.
withScope(String, ClientConfig) - Static method in interface io.pravega.client.SynchronizerClientFactory: Creates a new instance of Client Factory.
withScope(String, URI) - Static method in interface io.pravega.client.admin.ReaderGroupManager: Creates a new instance of ReaderGroupManager.
write(byte[], int, int) - Method in class io.pravega.client.byteStream.ByteStreamWriter: Writes the provided data to the segment.
write(ByteBuffer) - Method in class io.pravega.client.byteStream.ByteStreamWriter: Similar to ByteStreamWriter.write(byte[], int, int) Writes the provided data to the segment.
writeConditionally(Revision, T) - Method in interface io.pravega.client.state.RevisionedStreamClient: If the supplied revision is the latest revision in the stream write the provided value and return the new revision.
writeEvent(String, Sequence, Type) - Method in interface io.pravega.client.stream.IdempotentEventStreamWriter: Send an event to the stream.
writeEvent(String, Type) - Method in interface io.pravega.client.stream.EventStreamWriter: Write an event to the stream.
writeEvent(String, Type) - Method in interface io.pravega.client.stream.Transaction: Sends an event to the stream just like EventStreamWriter.writeEvent(Type) but with the caveat that the message will not be visible to anyone until Transaction.commit() is called.
writeEvent(Type) - Method in interface io.pravega.client.stream.EventStreamWriter: Send an event to the stream.
writeEvent(Type) - Method in interface io.pravega.client.stream.Transaction: Sends an event to the stream just like EventStreamWriter.writeEvent(Type) but with the caveat that the message will not be visible to anyone until Transaction.commit() is called.
writeEvents(String, List<Type>) - Method in interface io.pravega.client.stream.EventStreamWriter: Write an ordered list of events to the stream atomically for a given routing key.
writeUnconditionally(T) - Method in interface io.pravega.client.state.RevisionedStreamClient: Write a new value to the stream.

A B C D E F G H I J K L M N O P R S T U V W
All Classes All Packages