Package com.linkedin.venice.compute

Class CountOperator

java.lang.Object

com.linkedin.venice.compute.CountOperator

All Implemented Interfaces:

ReadComputeOperator

public class CountOperator
extends Object
implements ReadComputeOperator

Constructor Summary

Constructors

Constructor	Description
CountOperator()

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 operatorInputField, org.apache.avro.Schema.Field resultField, org.apache.avro.generic.GenericRecord inputValueRecord, org.apache.avro.generic.GenericRecord resultRecord, Map<String,String> computationErrorMap, Map<String,Object> context)
String	getOperatorFieldName(ComputeOperation op)
String	getResultFieldName(ComputeOperation op)
void	putDefaultResult(org.apache.avro.generic.GenericRecord record, org.apache.avro.Schema.Field field)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.venice.compute.ReadComputeOperator

putResult

Constructor Details

CountOperator

public CountOperator()

Method Details

compute

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

Specified by:

compute in interface ReadComputeOperator

getOperatorFieldName

public String getOperatorFieldName(ComputeOperation op)

Specified by:

getOperatorFieldName in interface ReadComputeOperator

getResultFieldName

public String getResultFieldName(ComputeOperation op)

Specified by:

getResultFieldName in interface ReadComputeOperator

putDefaultResult

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

Specified by:

putDefaultResult in interface ReadComputeOperator

allowFieldValueToBeNull

public boolean allowFieldValueToBeNull()

Description copied from interface: ReadComputeOperator

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

Specified by:

allowFieldValueToBeNull in interface ReadComputeOperator

Returns:

True if the extracted value is nullable and vice versa

toString

public String toString()

Overrides:

toString in class Object