Package com.linkedin.venice.client.store

Interface AvroGenericReadComputeStoreClient<K,V>

Type Parameters:

K -

V -

All Superinterfaces:

AutoCloseable, AvroGenericStoreClient<K,V>, Closeable

All Known Implementing Classes:

AbstractAvroStoreClient, AvroBlackHoleResponseStoreClientImpl, AvroGenericDaVinciClient, AvroGenericStoreClientImpl, AvroSpecificDaVinciClient, AvroSpecificStoreClientImpl, DelegatingAvroGenericDaVinciClient, DelegatingAvroStoreClient, DelegatingStoreClient, DispatchingAvroGenericStoreClient, DispatchingAvroSpecificStoreClient, DispatchingVsonStoreClient, DualReadAvroGenericStoreClient, DualReadAvroSpecificStoreClient, InternalAvroStoreClient, InternalAvroStoreClient, LoadControlledAvroGenericStoreClient, LoadControlledAvroSpecificStoreClient, LoggingTrackingStoreClient, RetriableAvroGenericStoreClient, RetriableAvroSpecificStoreClient, RetriableStoreClient, SpecificLoggingTrackingStoreClient, SpecificRetriableStoreClient, SpecificStatTrackingStoreClient, StatsAvroGenericDaVinciClient, StatsAvroGenericStoreClient, StatsAvroSpecificDaVinciClient, StatsAvroSpecificStoreClient, StatTrackingStoreClient, VersionSpecificAvroGenericDaVinciClient, VsonGenericStoreClientImpl

public interface AvroGenericReadComputeStoreClient<K,V>
extends AvroGenericStoreClient<K,V>

Venice avro generic client to provide read compute operations. This interface is internal and is subject to change.

Method Summary

Modifier and Type	Method	Description
default ComputeRequestBuilder<K>	compute()	This API allows performing transformations (projection, vector arithmetic and aggregations like count) on the values associated with the given set of keys.
void	compute(ComputeRequestWrapper computeRequestWrapper, Set<K> keys, org.apache.avro.Schema resultSchema, StreamingCallback<K,ComputeGenericRecord> callback, long preRequestTimeInNS)
default ComputeRequestBuilder<K>	compute(Optional<ClientStats> stats, AvroGenericReadComputeStoreClient computeStoreClient)
default ComputeRequestBuilder<K>	compute(Optional<ClientStats> stats, Optional<ClientStats> streamingStats, long preRequestTimeInNS)	Deprecated.
default ComputeRequestBuilder<K>	compute(Optional<ClientStats> stats, Optional<ClientStats> streamingStats, AvroGenericReadComputeStoreClient computeStoreClient, long preRequestTimeInNS)	Deprecated.
default ComputeAggregationRequestBuilder<K>	computeAggregation()	Create a new compute aggregation request builder.
void	computeWithKeyPrefixFilter(byte[] keyPrefix, ComputeRequestWrapper computeRequestWrapper, StreamingCallback<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> callback)
SchemaReader	getSchemaReader()
boolean	isProjectionFieldValidationEnabled()

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

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

Method Details

getSchemaReader

SchemaReader getSchemaReader()

isProjectionFieldValidationEnabled

boolean isProjectionFieldValidationEnabled()

compute

default ComputeRequestBuilder<K> compute()
                                  throws VeniceClientException

Description copied from interface: AvroGenericStoreClient

This API allows performing transformations (projection, vector arithmetic and aggregations like count) on the values associated with the given set of keys. Check out ComputeRequestBuilder for details on the available operations.

Specified by:

compute in interface AvroGenericStoreClient<K,V>

Throws:

VeniceClientException

See Also:

• ComputeRequestBuilder

compute

@Deprecated
default ComputeRequestBuilder<K> compute(Optional<ClientStats> stats,
 Optional<ClientStats> streamingStats,
 long preRequestTimeInNS)
                                  throws VeniceClientException

Deprecated.

Throws:

VeniceClientException

compute

@Deprecated
default ComputeRequestBuilder<K> compute(Optional<ClientStats> stats,
 Optional<ClientStats> streamingStats,
 AvroGenericReadComputeStoreClient computeStoreClient,
 long preRequestTimeInNS)
                                  throws VeniceClientException

Deprecated.

Throws:

VeniceClientException

compute

default ComputeRequestBuilder<K> compute(Optional<ClientStats> stats,
 AvroGenericReadComputeStoreClient computeStoreClient)
                                  throws VeniceClientException

Throws:

VeniceClientException

compute

void compute(ComputeRequestWrapper computeRequestWrapper,
 Set<K> keys,
 org.apache.avro.Schema resultSchema,
 StreamingCallback<K,ComputeGenericRecord> callback,
 long preRequestTimeInNS)
      throws VeniceClientException

Throws:

VeniceClientException

computeWithKeyPrefixFilter

void computeWithKeyPrefixFilter(byte[] keyPrefix,
 ComputeRequestWrapper computeRequestWrapper,
 StreamingCallback<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> callback)
                         throws VeniceClientException

Throws:

VeniceClientException

computeAggregation

default ComputeAggregationRequestBuilder<K> computeAggregation()
                                                        throws VeniceClientException

Create a new compute aggregation request builder.

Returns:

A new ComputeAggregationRequestBuilder instance.

Throws:

VeniceClientException - if there is an error creating the builder.