com.yahoo.bullet.querying

Class QueryCategorizer

java.lang.Object

com.yahoo.bullet.querying.QueryCategorizer

public class QueryCategorizer
extends Object

This categorizes running queries into whether they are done, closed, have exceeded the rate limits or have new data. Running queries are provided as a Map of String query IDs to non-null, valid, initialized Querier objects.

Use categorize(Map) and categorize(BulletRecord, Map)for categorizing queries. The latter categorizes after making the Querier instances Querier.consume(BulletRecord).

Constructor Summary

Constructors

Constructor and Description
QueryCategorizer()

Method Summary

Modifier and Type	Method and Description
QueryCategorizer	categorize(com.yahoo.bullet.record.BulletRecord record, Map<String,Querier> queries) Categorize the given Map of query IDs to Querier instances after consuming the given record.
QueryCategorizer	categorize(Map<String,Querier> queries) Categorize the given Map of query IDs to Querier instances.

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryCategorizer

public QueryCategorizer()

Method Detail

categorize

public QueryCategorizer categorize(Map<String,Querier> queries)

Categorize the given Map of query IDs to Querier instances.

Parameters:

queries - The queries to categorize.

Returns:

This object for chaining.

categorize

public QueryCategorizer categorize(com.yahoo.bullet.record.BulletRecord record,
                                   Map<String,Querier> queries)

Categorize the given Map of query IDs to Querier instances after consuming the given record.

Parameters:

record - The BulletRecord to consume first.

queries - The queries to categorize.

Returns:

This object for chaining.