Serialized Form
-
Package io.pravega.client
-
Class io.pravega.client.ClientConfig extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
controllerURI
java.net.URI controllerURI
controllerURI The controller rpc URI. This can be of 2 types 1. tcp://ip1:port1,ip2:port2,... This is used if the controller endpoints are static and can be directly accessed. 2. pravega://ip1:port1,ip2:port2,... This is used to autodiscovery the controller endpoints from an initial controller list. -
credentials
io.pravega.shared.security.auth.Credentials credentials
Credentials to be passed on to the Pravega controller for authentication and authorization. -
deriveTlsEnabledFromControllerURI
boolean deriveTlsEnabledFromControllerURI
An internal property that determines whether TLS enabled is derived from Controller URI. It cannot be set directly by the caller. It is interpreted as: false - ifClientConfig.enableTlsToController
and/orClientConfig.enableTlsToSegmentStore
is/are set, and if either of them is set to false. true - if neitherClientConfig.enableTlsToController
orClientConfig.enableTlsToSegmentStore
are set, or if both are set to true. -
enableTlsToController
boolean enableTlsToController
An optional property representing whether to enable TLS for client's communication with the Controller. If this property andClientConfig.enableTlsToSegmentStore
are not set, and the scheme used inClientConfig.controllerURI
istls
orpravegas
, TLS is automatically enabled for both client-to-Controller and client-to-Segment Store communications. -
enableTlsToSegmentStore
boolean enableTlsToSegmentStore
An optional property representing whether to enable TLS for client's communication with the Controller. If this property andClientConfig.enableTlsToController
are not set, and the scheme used inClientConfig.controllerURI
istls
orpravegas
, TLS is automatically enabled for both client-to-Controller and client-to-Segment Store communications. -
maxConnectionsPerSegmentStore
int maxConnectionsPerSegmentStore
Maximum number of connections per Segment store to be used by connection pooling. -
metricListener
io.pravega.shared.metrics.MetricListener metricListener
An optional listener which can be used to get performance metrics from the client. The user can implement this interface to obtain performance metrics of the client. -
trustStore
java.lang.String trustStore
Path to an optional truststore. If this is null or empty, the default JVM trust store is used. This is currently expected to be a signing certificate for the certification authority. -
validateHostName
boolean validateHostName
If the flagClientConfig.isEnableTls()
is set, this flag decides whether to enable host name validation or not.
-
-
-
Package io.pravega.client.batch
-
Package io.pravega.client.state
-
Class io.pravega.client.state.SynchronizerConfig extends java.lang.Object implements Serializable
- serialVersionUID:
- 2L
-
Serialized Fields
-
eventWriterConfig
EventWriterConfig eventWriterConfig
This writer config is used by the segment writers in the StateSyncrhonizer. The default values enable connection pooling and ensures the background connection retry attempts continue until the StateSyncrhonizer is closed. -
readBufferSize
int readBufferSize
This size is used to allocate buffer space for the bytes the reader in the StateSyncrhonizer reads from the segment. The default buffer size is 256KB.
-
-
-
Package io.pravega.client.stream
-
Class io.pravega.client.stream.DeleteScopeFailedException extends java.lang.Exception implements Serializable
- serialVersionUID:
- 1L
-
Class io.pravega.client.stream.EventWriterConfig extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
automaticallyNoteTime
boolean automaticallyNoteTime
Automatically invokeEventStreamWriter.noteTime(long)
passingSystem.currentTimeMillis()
on a regular interval. -
backoffMultiple
int backoffMultiple
-
enableConnectionPooling
boolean enableConnectionPooling
-
initialBackoffMillis
int initialBackoffMillis
-
maxBackoffMillis
int maxBackoffMillis
-
retryAttempts
int retryAttempts
-
transactionTimeoutTime
long transactionTimeoutTime
-
-
Class io.pravega.client.stream.InvalidStreamException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- 1L
-
Class io.pravega.client.stream.NoSuchScopeException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- 1L
-
Class io.pravega.client.stream.PingFailedException extends java.lang.Exception implements Serializable
- serialVersionUID:
- 1L
-
Class io.pravega.client.stream.ReaderConfig extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
bufferSize
int bufferSize
-
disableTimeWindows
boolean disableTimeWindows
-
initialAllocationDelay
long initialAllocationDelay
-
-
Class io.pravega.client.stream.ReaderGroupConfig extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
automaticCheckpointIntervalMillis
long automaticCheckpointIntervalMillis
-
endingStreamCuts
java.util.Map<Stream,StreamCut> endingStreamCuts
-
generation
long generation
-
groupRefreshTimeMillis
long groupRefreshTimeMillis
-
maxOutstandingCheckpointRequest
int maxOutstandingCheckpointRequest
-
readerGroupId
java.util.UUID readerGroupId
-
retentionType
ReaderGroupConfig.StreamDataRetention retentionType
-
startingStreamCuts
java.util.Map<Stream,StreamCut> startingStreamCuts
-
-
Class io.pravega.client.stream.ReaderNotInReaderGroupException extends java.lang.Exception implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
readerId
java.lang.String readerId
-
-
Class io.pravega.client.stream.ReinitializationRequiredException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- 1L
-
Class io.pravega.client.stream.RetentionPolicy extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
retentionMax
long retentionMax
-
retentionParam
long retentionParam
-
retentionType
RetentionPolicy.RetentionType retentionType
-
-
Class io.pravega.client.stream.ScalingPolicy extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
minNumSegments
int minNumSegments
-
scaleFactor
int scaleFactor
-
scaleType
ScalingPolicy.ScaleType scaleType
-
targetRate
int targetRate
-
-
Class io.pravega.client.stream.Sequence extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialization Methods
-
writeReplace
private java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
Serialized Fields
-
highOrder
long highOrder
-
lowOrder
long lowOrder
-
-
Class io.pravega.client.stream.StreamConfiguration extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
retentionPolicy
RetentionPolicy retentionPolicy
API to return retention policy. Also see:ReaderGroupConfig.StreamDataRetention
-
scalingPolicy
ScalingPolicy scalingPolicy
API to return scaling policy. -
timestampAggregationTimeout
long timestampAggregationTimeout
The duration after the last call toEventStreamWriter.noteTime(long)
which the timestamp should be considered valid before it is forgotten. Meaning that after this long of not callingEventStreamWriter.noteTime(long)
the writer will be forgotten. If there are no known writers, readers that callEventStreamReader.getCurrentTimeWindow(Stream)
will receive a `null` when they are at the corresponding position in the stream. which the timestamp should be considered valid before it is forgotten. be considered valid before it is forgotten.
-
-
Class io.pravega.client.stream.TruncatedDataException extends java.lang.RuntimeException implements Serializable
- serialVersionUID:
- 1L
-
Class io.pravega.client.stream.TxnFailedException extends java.lang.Exception implements Serializable
- serialVersionUID:
- 1L
-
-
Package io.pravega.client.tables
-
Class io.pravega.client.tables.BadKeyVersionException extends ConditionalTableUpdateException implements Serializable
-
Class io.pravega.client.tables.ConditionalTableUpdateException extends java.lang.Exception implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
tableName
java.lang.String tableName
-
-
Class io.pravega.client.tables.KeyValueTableClientConfiguration extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
backoffMultiple
int backoffMultiple
-
initialBackoffMillis
int initialBackoffMillis
-
maxBackoffMillis
int maxBackoffMillis
-
retryAttempts
int retryAttempts
-
-
Class io.pravega.client.tables.KeyValueTableConfiguration extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
partitionCount
int partitionCount
The number of Partitions for a Key-Value Table. This value cannot be adjusted after the Key-Value Table has been created.
-
-
Class io.pravega.client.tables.KeyVersion extends java.lang.Object implements Serializable
-
Serialized Fields
-
segmentName
java.lang.String segmentName
The Segment where this Key resides. May be null if this is aKeyVersion.NOT_EXISTS
orKeyVersion.NO_VERSION
KeyVersion
. -
segmentVersion
io.pravega.client.tables.impl.TableSegmentKeyVersion segmentVersion
The internal version inside the Table Segment for this Key.
-
-
-
Class io.pravega.client.tables.NoSuchKeyException extends ConditionalTableUpdateException implements Serializable
-