Package com.linkedin.venice.client.store

Class AvroComputeAggregationResponse<K>

java.lang.Object

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

All Implemented Interfaces:

ComputeAggregationResponse

public class AvroComputeAggregationResponse<K>
extends Object
implements ComputeAggregationResponse

Implementation of ComputeAggregationResponse that handles the results of count-by-value and count-by-bucket aggregations.

Constructor Summary

Constructors

Constructor	Description
AvroComputeAggregationResponse(Map<K,ComputeGenericRecord> computeResults, Map<String,Integer> fieldTopKMap)
AvroComputeAggregationResponse(Map<K,ComputeGenericRecord> computeResults, Map<String,Integer> fieldTopKMap, Map<String,Map<String,Predicate>> fieldBucketMap)

Method Summary

Modifier and Type	Method	Description
Map<String,Integer>	getBucketNameToCount(String fieldName)
<T> Map<T,Integer>	getValueToCount(String field)

Methods inherited from class java.lang.Object

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

Constructor Details

AvroComputeAggregationResponse

public AvroComputeAggregationResponse(Map<K,ComputeGenericRecord> computeResults,
 Map<String,Integer> fieldTopKMap)

AvroComputeAggregationResponse

public AvroComputeAggregationResponse(Map<K,ComputeGenericRecord> computeResults,
 Map<String,Integer> fieldTopKMap,
 Map<String,Map<String,Predicate>> fieldBucketMap)

Method Details

getValueToCount

public <T> Map<T,Integer> getValueToCount(String field)

Specified by:

getValueToCount in interface ComputeAggregationResponse

Parameters:

field - for which to get the value -> count map

Returns:

the value counts as defined by ComputeAggregationRequestBuilder.countGroupByValue(int, String...)

getBucketNameToCount

public Map<String,Integer> getBucketNameToCount(String fieldName)

Specified by:

getBucketNameToCount in interface ComputeAggregationResponse

Parameters:

fieldName - for which to get the bucket -> count map

Returns:

the bucket counts as defined by ComputeAggregationRequestBuilder.countGroupByBucket(Map, String...)