Package com.linkedin.davinci.client

Class AvroGenericSeekableDaVinciClient<K,V>

java.lang.Object

com.linkedin.davinci.client.AvroGenericDaVinciClient<K,V>

com.linkedin.davinci.client.AvroGenericSeekableDaVinciClient<K,V>

All Implemented Interfaces:

DaVinciClient<K,V>, SeekableDaVinciClient<K,V>, AvroGenericReadComputeStoreClient<K,V>, AvroGenericStoreClient<K,V>, Closeable, AutoCloseable

public class AvroGenericSeekableDaVinciClient<K,V>
extends AvroGenericDaVinciClient<K,V>
implements SeekableDaVinciClient<K,V>

Field Summary

Fields inherited from class com.linkedin.davinci.client.AvroGenericDaVinciClient

DEFAULT_CHUNK_SPLIT_THRESHOLD, logger, READ_CHUNK_EXECUTOR, storeBackend, subscription

Constructor Summary

Constructors

Constructor	Description
AvroGenericSeekableDaVinciClient(DaVinciConfig daVinciConfig, ClientConfig clientConfig, VeniceProperties backendConfig, Optional<Set<String>> managedClients, ICProvider icProvider, Executor readChunkExecutorForLargeRequest)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	seekToBeginningOfPush(Set<Integer> partitions)	Seek to the begining of the push, for the specified partitions.
CompletableFuture<Void>	seekToCheckpoint(Set<VeniceChangeCoordinate> checkpoints)	Seek the provided checkpoints for the specified partitions.
CompletableFuture<Void>	seekToTail()	Seek to the end of the last push for all subscribed partitions.
CompletableFuture<Void>	seekToTail(Set<Integer> partitions)	Seek to the end of the last push for the specified partitions.
CompletableFuture<Void>	seekToTimestamp(Long timestamp)	Seek to the specified timestamp for all subscribed partitions.
CompletableFuture<Void>	seekToTimestamps(Map<Integer,Long> timestamps)	Seek to the specified timestamps for partitions and corresponding timestamps in the map.

Methods inherited from class com.linkedin.davinci.client.AvroGenericDaVinciClient

addPartitionsToSubscription, batchGet, close, compute, compute, computeWithKeyPrefixFilter, discoverService, get, get, getAvroChunkingAdapter, getBackend, getGenericRecordChunkingAdapter, getKeySchema, getLatestValueSchema, getPartitionCount, getSchemaReader, getStoreName, getStoreVersion, initBackend, isPartitionReadyToServe, isPartitionSubscribed, isProjectionFieldValidationEnabled, isReady, seekToTimestamps, split, start, streamingBatchGet, subscribe, subscribe, subscribeAll, throwIfNotReady, toString, unsubscribe, unsubscribe, unsubscribeAll

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.linkedin.venice.client.store.AvroGenericReadComputeStoreClient

compute, compute, compute, computeAggregation

Methods inherited from interface com.linkedin.venice.client.store.AvroGenericStoreClient

batchGet, close, get, get, getKeySchema, getLatestValueSchema, getStoreName, start, streamingBatchGet, streamingBatchGet

Methods inherited from interface com.linkedin.davinci.client.DaVinciClient

getPartitionCount, subscribe, subscribeAll, unsubscribe, unsubscribeAll

Constructor Details

AvroGenericSeekableDaVinciClient

public AvroGenericSeekableDaVinciClient(DaVinciConfig daVinciConfig,
 ClientConfig clientConfig,
 VeniceProperties backendConfig,
 Optional<Set<String>> managedClients,
 ICProvider icProvider,
 Executor readChunkExecutorForLargeRequest)

Method Details

seekToTimestamps

public CompletableFuture<Void> seekToTimestamps(Map<Integer,Long> timestamps)

Description copied from interface: SeekableDaVinciClient

Seek to the specified timestamps for partitions and corresponding timestamps in the map.

Specified by:

seekToTimestamps in interface SeekableDaVinciClient<K,V>

Overrides:

seekToTimestamps in class AvroGenericDaVinciClient<K,V>

seekToTimestamp

public CompletableFuture<Void> seekToTimestamp(Long timestamp)

Description copied from interface: SeekableDaVinciClient

Seek to the specified timestamp for all subscribed partitions.

Specified by:

seekToTimestamp in interface SeekableDaVinciClient<K,V>

seekToBeginningOfPush

public CompletableFuture<Void> seekToBeginningOfPush(Set<Integer> partitions)

Description copied from interface: SeekableDaVinciClient

Seek to the begining of the push, for the specified partitions. Same as unsubscribe and subscribe.

Specified by:

seekToBeginningOfPush in interface SeekableDaVinciClient<K,V>

Returns:

seekToCheckpoint

public CompletableFuture<Void> seekToCheckpoint(Set<VeniceChangeCoordinate> checkpoints)

Description copied from interface: SeekableDaVinciClient

Seek the provided checkpoints for the specified partitions. Note about checkpoints: Checkpoints have the following properties and should be considered: - Checkpoints are NOT comparable or valid across partitions. - Checkpoints are NOT comparable or valid across regions - Checkpoints are NOT comparable across store versions - It is not possible to determine the number of events between two checkpoints - It is possible that a checkpoint is no longer on retention. In such case, we will return an exception to the caller.

Specified by:

seekToCheckpoint in interface SeekableDaVinciClient<K,V>

Overrides:

seekToCheckpoint in class AvroGenericDaVinciClient<K,V>

Returns:

a future which completes when seek has completed for all partitions

seekToTail

public CompletableFuture<Void> seekToTail()

Description copied from interface: SeekableDaVinciClient

Seek to the end of the last push for all subscribed partitions.

Specified by:

seekToTail in interface SeekableDaVinciClient<K,V>

Returns:

a future which completes when the operation has succeeded for all partitions.

seekToTail

public CompletableFuture<Void> seekToTail(Set<Integer> partitions)

Description copied from interface: SeekableDaVinciClient

Seek to the end of the last push for the specified partitions.

Specified by:

seekToTail in interface SeekableDaVinciClient<K,V>

Parameters:

partitions - the set of partitions to seek with

Returns:

a future which completes when the operation has succeeded for all partitions.