Package com.linkedin.davinci.client

Interface SeekableDaVinciClient<K,V>

All Superinterfaces:
AutoCloseable, AvroGenericStoreClient<K,V>, Closeable, DaVinciClient<K,V>
All Known Implementing Classes:
AvroGenericSeekableDaVinciClient
public interface SeekableDaVinciClient<K,V> extends DaVinciClient<K,V>

  • Method Details

    • seekToTimestamps

      CompletableFuture<Void> seekToTimestamps(Map<Integer,Long> timestamps)
      Seek to the specified timestamps for partitions and corresponding timestamps in the map.
      Parameters:
      timestamps -

    • seekToTimestamp

      CompletableFuture<Void> seekToTimestamp(Long timestamp)
      Seek to the specified timestamp for all subscribed partitions.
      Parameters:
      timestamp -

    • seekToBeginningOfPush

      CompletableFuture<Void> seekToBeginningOfPush(Set<Integer> partitions)
      Seek to the begining of the push, for the specified partitions. Same as unsubscribe and subscribe.
      Parameters:
      partitions -
      Returns:

    • seekToCheckpoint

      CompletableFuture<Void> seekToCheckpoint(Set<VeniceChangeCoordinate> checkpoints)
      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.
      Parameters:
      checkpoints -
      Returns:
      a future which completes when seek has completed for all partitions
      Throws:
      VeniceException - if seek operation failed for any of the partitions

    • seekToTail

      CompletableFuture<Void> seekToTail()
      Seek to the end of the last push for all subscribed partitions.
      Returns:
      a future which completes when the operation has succeeded for all partitions.
      Throws:
      VeniceException - if seek operation failed for any of the partitions, or seeking was performed on unsubscribed partitions

    • seekToTail

      CompletableFuture<Void> seekToTail(Set<Integer> partitions)
      Seek to the end of the last push for the specified partitions.
      Parameters:
      partitions - the set of partitions to seek with
      Returns:
      a future which completes when the operation has succeeded for all partitions.
      Throws:
      VeniceException - if seek operation failed for any of the partitions, or seeking was performed on unsubscribed partitions