Package com.linkedin.venice.client.store

Class AvroComputeRequestBuilderV4<K>

java.lang.Object

com.linkedin.venice.client.store.AbstractAvroComputeRequestBuilder<K>

com.linkedin.venice.client.store.AvroComputeRequestBuilderV3<K>

com.linkedin.venice.client.store.AvroComputeRequestBuilderV4<K>

All Implemented Interfaces:

ComputeRequestBuilder<K>

public class AvroComputeRequestBuilderV4<K>
extends AvroComputeRequestBuilderV3<K>

Field Summary

Fields inherited from class com.linkedin.venice.client.store.AbstractAvroComputeRequestBuilder

COSINE_SIMILARITY_RESULT_SCHEMA, COSINE_SIMILARITY_SPEC, DOT_PRODUCT_RESULT_SCHEMA, DOT_PRODUCT_SPEC, HADAMARD_PRODUCT_RESULT_SCHEMA, HADAMARD_PRODUCT_SPEC, latestValueSchema, latestValueSchemaId, PROJECTION_SPEC, RESULT_SCHEMA_CACHE, resultSchemaName, storeClient

Constructor Summary

Constructors

Constructor	Description
AvroComputeRequestBuilderV4(AvroGenericReadComputeStoreClient storeClient, SchemaReader schemaReader)

Method Summary

Modifier and Type	Method	Description
void	executeWithFilter(Predicate requiredPrefixFields, StreamingCallback<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> callback)	Streaming interface that sends compute request to Venice, which will be executed on values whose keys satisfy the given predicate.

Methods inherited from class com.linkedin.venice.client.store.AvroComputeRequestBuilderV3

count, getComputeRequestOperations, getResultSchema

Methods inherited from class com.linkedin.venice.client.store.AbstractAvroComputeRequestBuilder

checkComputeFieldValidity, commonValidityCheck, cosineSimilarity, dotProduct, execute, generateComputeRequest, getCommonComputeSpec, getCommonResultFields, hadamardProduct, project, project, setStats, setTime, setValidateProjectionFields, streamingExecute, streamingExecute

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroComputeRequestBuilderV4

public AvroComputeRequestBuilderV4(AvroGenericReadComputeStoreClient storeClient,
                                   SchemaReader schemaReader)

Method Detail

executeWithFilter

public void executeWithFilter(Predicate requiredPrefixFields,
                              StreamingCallback<org.apache.avro.generic.GenericRecord,org.apache.avro.generic.GenericRecord> callback)

Description copied from interface: ComputeRequestBuilder

Streaming interface that sends compute request to Venice, which will be executed on values whose keys satisfy the given predicate. This can be used to execute partial key lookups. If predicate is null, the compute request will be executed on all values. You can find more info in StreamingCallback. This experimental feature is subject to backwards-incompatible changes in the future.

Specified by:

executeWithFilter in interface ComputeRequestBuilder<K>

Overrides:

executeWithFilter in class AvroComputeRequestBuilderV3<K>

Parameters:

requiredPrefixFields - : predicate which specifies some required leading top-level key fields

callback - : streaming callback which stores the result from the compute request