Package com.linkedin.venice.compute

Interface ReadComputeOperator

All Known Implementing Classes:

CosineSimilarityOperator, CountOperator, DotProductOperator, HadamardProductOperator

public interface ReadComputeOperator

Method Summary

Modifier and Type	Method	Description
boolean	allowFieldValueToBeNull()	Whether the extracted value of the field in the read value record is allowed to be null.
void	compute(ComputeOperation op, org.apache.avro.Schema.Field operatorField, org.apache.avro.Schema.Field resultField, org.apache.avro.generic.GenericRecord valueRecord, org.apache.avro.generic.GenericRecord resultRecord, Map<String,String> computationErrorMap, Map<String,Object> context)
String	getOperatorFieldName(ComputeOperation op)
String	getResultFieldName(ComputeOperation op)
default void	putDefaultResult(org.apache.avro.generic.GenericRecord record, org.apache.avro.Schema.Field field)
default void	putResult(org.apache.avro.generic.GenericRecord record, org.apache.avro.Schema.Field field, Object result)

Method Details

compute

void compute(ComputeOperation op,
 org.apache.avro.Schema.Field operatorField,
 org.apache.avro.Schema.Field resultField,
 org.apache.avro.generic.GenericRecord valueRecord,
 org.apache.avro.generic.GenericRecord resultRecord,
 Map<String,String> computationErrorMap,
 Map<String,Object> context)

putResult

default void putResult(org.apache.avro.generic.GenericRecord record,
 org.apache.avro.Schema.Field field,
 Object result)

putDefaultResult

default void putDefaultResult(org.apache.avro.generic.GenericRecord record,
 org.apache.avro.Schema.Field field)

getResultFieldName

String getResultFieldName(ComputeOperation op)

getOperatorFieldName

String getOperatorFieldName(ComputeOperation op)

allowFieldValueToBeNull

boolean allowFieldValueToBeNull()

Whether the extracted value of the field in the read value record is allowed to be null.

Returns:

True if the extracted value is nullable and vice versa