Package com.linkedin.venice.fastclient.meta

Class RequestBasedMetadata

java.lang.Object
com.linkedin.venice.fastclient.meta.AbstractStoreMetadata
com.linkedin.venice.fastclient.meta.RequestBasedMetadata
All Implemented Interfaces:
StoreMetadata, SchemaReader, Closeable, AutoCloseable
public class RequestBasedMetadata extends AbstractStoreMetadata
Store metadata class that uses the server's endpoint to fetch metadata and keep the local cache up to date.

  • Field Details

    • DEFAULT_REFRESH_INTERVAL_IN_SECONDS

      public static final long DEFAULT_REFRESH_INTERVAL_IN_SECONDS
      See Also:

    • DEFAULT_CONN_WARMUP_TIMEOUT_IN_SECONDS_DEFAULT

      public static final long DEFAULT_CONN_WARMUP_TIMEOUT_IN_SECONDS_DEFAULT
      See Also:

  • Constructor Details

  • Method Details

    • getClusterName

      public String getClusterName()

    • getCurrentStoreVersion

      public int getCurrentStoreVersion()

    • getPartitionId

      public int getPartitionId(int version, ByteBuffer key)

    • getReplicas

      public List<String> getReplicas(int version, int partitionId)

    • start

      public void start()

    • whetherToSwitchToFetchedCurrentVersion

      public static boolean whetherToSwitchToFetchedCurrentVersion(String storeName, Set<Integer> activeVersions, AtomicInteger currentVersion, int fetchedCurrentVersion, int partitionCountForFetchedCurrentVersion, Map<Integer,List<String>> routingInfo)

    • isPartitionResourcesReady

      public static boolean isPartitionResourcesReady(String storeName, int version, int partitionCount, Map<Integer,List<String>> routingInfo)

    • close

      public void close() throws IOException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Overrides:
      close in class AbstractStoreMetadata
      Throws:
      IOException

    • getCompressor

      public VeniceCompressor getCompressor(CompressionStrategy compressionStrategy, int version)

    • getCompressionStrategy

      public CompressionStrategy getCompressionStrategy(int version)
      Description copied from interface: StoreMetadata
      Returns the CompressionStrategy configured for the given store version.

      The strategy is delivered to this metadata instance via the per-version versionProperties on each metadata-refresh response. The Fast Client's decompressAndDeserialize seam uses this internally to resolve the per-version compressor when decoding out-of-band value bytes.

      External integration layers should not call this directly — use AvroGenericStoreClient.decompressAndDeserialize(java.nio.ByteBuffer, int, Object) instead, which handles the version → strategy → compressor → schema id resolution behind a single call.

      Unknown-version contract. The canonical AbstractStoreMetadata-derived implementation throws VeniceClientException on a version it has never observed (e.g. caller typo, or a version evicted from the active set on a prior refresh). The default implementation here returns CompressionStrategy.NO_OP so that lightweight test fakes do not need to track per-version state — fake-based tests should not pass unknown versions to begin with.

    • getKeySchema

      public org.apache.avro.Schema getKeySchema()

    • getValueSchema

      public org.apache.avro.Schema getValueSchema(int id)

    • getValueSchemaId

      public int getValueSchemaId(org.apache.avro.Schema schema)
      Description copied from interface: SchemaReader
      Return the schema ID of any schema that has the same parsing canonical form as the schema provided. If multiple schemas have the same parsing canonical form, return the one with the largest ID.
      Parameters:
      schema - The schema for which the schema ID is needed
      Returns:
      The ID of the schema that has the same parsing canonical form as the schema provided

    • getLatestValueSchema

      public org.apache.avro.Schema getLatestValueSchema()

    • getLatestValueSchemaId

      public Integer getLatestValueSchemaId()
      Description copied from interface: SchemaReader
      Get the latest value schema id. This may be different from the value schema with the largest id if the superset schema is not the value schema with the largest id

    • getUpdateSchema

      public org.apache.avro.Schema getUpdateSchema(int valueSchemaId)

    • getLatestUpdateSchema

      public DerivedSchemaEntry getLatestUpdateSchema()

    • isReady

      public boolean isReady()

    • getBatchGetLimit

      public int getBatchGetLimit()
      Specified by:
      getBatchGetLimit in interface StoreMetadata
      Overrides:
      getBatchGetLimit in class AbstractStoreMetadata

    • setD2ServiceDiscovery

      public void setD2ServiceDiscovery(D2ServiceDiscovery d2ServiceDiscovery)
      Used for test only
      Parameters:
      d2ServiceDiscovery -

    • setScheduler

      public void setScheduler(ScheduledExecutorService scheduler)

    • getScheduler

      public ScheduledExecutorService getScheduler()

    • setIsReadyLatch

      public void setIsReadyLatch(CountDownLatch isReadyLatch)

    • getIsReadyLatch

      public CountDownLatch getIsReadyLatch()

    • setRefreshIntervalInSeconds

      public void setRefreshIntervalInSeconds(long refreshIntervalInSeconds)

    • getRefreshIntervalInSeconds

      public long getRefreshIntervalInSeconds()

    • getWarmUpInstancesFutures

      public Map<String,CompletableFuture> getWarmUpInstancesFutures()

    • setWarmUpInstancesFutures

      public void setWarmUpInstancesFutures(Map<String,CompletableFuture> warmUpInstancesFutures)