io.druid.query

Class QueryContexts

java.lang.Object

io.druid.query.QueryContexts

public class QueryContexts
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHUNK_PERIOD_KEY
static boolean	DEFAULT_BY_SEGMENT
static boolean	DEFAULT_POPULATE_CACHE
static int	DEFAULT_PRIORITY
static String	DEFAULT_TIMEOUT_KEY
static long	DEFAULT_TIMEOUT_MILLIS
static int	DEFAULT_UNCOVERED_INTERVALS_LIMIT
static boolean	DEFAULT_USE_CACHE
static String	MAX_SCATTER_GATHER_BYTES_KEY
static long	NO_TIMEOUT
static String	PRIORITY_KEY
static String	TIMEOUT_KEY

Constructor Summary

Constructors

Constructor and Description
QueryContexts()

Method Summary

Modifier and Type	Method and Description
static <T> String	getChunkPeriod(Query<T> query)
static <T> long	getMaxScatterGatherBytes(Query<T> query)
static <T> int	getPriority(Query<T> query)
static <T> int	getPriority(Query<T> query, int defaultValue)
static <T> long	getTimeout(Query<T> query)
static <T> long	getTimeout(Query<T> query, long defaultTimeout)
static <T> int	getUncoveredIntervalsLimit(Query<T> query)
static <T> int	getUncoveredIntervalsLimit(Query<T> query, int defaultValue)
static <T> boolean	hasTimeout(Query<T> query)
static <T> boolean	isBySegment(Query<T> query)
static <T> boolean	isBySegment(Query<T> query, boolean defaultValue)
static <T> boolean	isFinalize(Query<T> query, boolean defaultValue)
static <T> boolean	isPopulateCache(Query<T> query)
static <T> boolean	isPopulateCache(Query<T> query, boolean defaultValue)
static <T> boolean	isSerializeDateTimeAsLong(Query<T> query, boolean defaultValue)
static <T> boolean	isSerializeDateTimeAsLongInner(Query<T> query, boolean defaultValue)
static <T> boolean	isUseCache(Query<T> query)
static <T> boolean	isUseCache(Query<T> query, boolean defaultValue)
static <T> Query<T>	verifyMaxQueryTimeout(Query<T> query, long maxQueryTimeout)
static <T> Query<T>	withDefaultTimeout(Query<T> query, long defaultTimeout)
static <T> Query<T>	withMaxScatterGatherBytes(Query<T> query, long maxScatterGatherBytesLimit)
static <T> Query<T>	withTimeout(Query<T> query, long timeout)

Methods inherited from class java.lang.Object

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

Field Detail

PRIORITY_KEY

public static final String PRIORITY_KEY

See Also:

Constant Field Values

TIMEOUT_KEY

public static final String TIMEOUT_KEY

See Also:

Constant Field Values

MAX_SCATTER_GATHER_BYTES_KEY

public static final String MAX_SCATTER_GATHER_BYTES_KEY

See Also:

Constant Field Values

DEFAULT_TIMEOUT_KEY

public static final String DEFAULT_TIMEOUT_KEY

See Also:

Constant Field Values

CHUNK_PERIOD_KEY

public static final String CHUNK_PERIOD_KEY

See Also:

Constant Field Values

DEFAULT_BY_SEGMENT

public static final boolean DEFAULT_BY_SEGMENT

See Also:

Constant Field Values

DEFAULT_POPULATE_CACHE

public static final boolean DEFAULT_POPULATE_CACHE

See Also:

Constant Field Values

DEFAULT_USE_CACHE

public static final boolean DEFAULT_USE_CACHE

See Also:

Constant Field Values

DEFAULT_PRIORITY

public static final int DEFAULT_PRIORITY

See Also:

Constant Field Values

DEFAULT_UNCOVERED_INTERVALS_LIMIT

public static final int DEFAULT_UNCOVERED_INTERVALS_LIMIT

See Also:

Constant Field Values

DEFAULT_TIMEOUT_MILLIS

public static final long DEFAULT_TIMEOUT_MILLIS

See Also:

Constant Field Values

NO_TIMEOUT

public static final long NO_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

QueryContexts

public QueryContexts()

Method Detail

isBySegment

public static <T> boolean isBySegment(Query<T> query)

isBySegment

public static <T> boolean isBySegment(Query<T> query,
                                      boolean defaultValue)

isPopulateCache

public static <T> boolean isPopulateCache(Query<T> query)

isPopulateCache

public static <T> boolean isPopulateCache(Query<T> query,
                                          boolean defaultValue)

isUseCache

public static <T> boolean isUseCache(Query<T> query)

isUseCache

public static <T> boolean isUseCache(Query<T> query,
                                     boolean defaultValue)

isFinalize

public static <T> boolean isFinalize(Query<T> query,
                                     boolean defaultValue)

isSerializeDateTimeAsLong

public static <T> boolean isSerializeDateTimeAsLong(Query<T> query,
                                                    boolean defaultValue)

isSerializeDateTimeAsLongInner

public static <T> boolean isSerializeDateTimeAsLongInner(Query<T> query,
                                                         boolean defaultValue)

getUncoveredIntervalsLimit

public static <T> int getUncoveredIntervalsLimit(Query<T> query)

getUncoveredIntervalsLimit

public static <T> int getUncoveredIntervalsLimit(Query<T> query,
                                                 int defaultValue)

getPriority

public static <T> int getPriority(Query<T> query)

getPriority

public static <T> int getPriority(Query<T> query,
                                  int defaultValue)

getChunkPeriod

public static <T> String getChunkPeriod(Query<T> query)

withMaxScatterGatherBytes

public static <T> Query<T> withMaxScatterGatherBytes(Query<T> query,
                                                     long maxScatterGatherBytesLimit)

verifyMaxQueryTimeout

public static <T> Query<T> verifyMaxQueryTimeout(Query<T> query,
                                                 long maxQueryTimeout)

getMaxScatterGatherBytes

public static <T> long getMaxScatterGatherBytes(Query<T> query)

hasTimeout

public static <T> boolean hasTimeout(Query<T> query)

getTimeout

public static <T> long getTimeout(Query<T> query)

getTimeout

public static <T> long getTimeout(Query<T> query,
                                  long defaultTimeout)

withTimeout

public static <T> Query<T> withTimeout(Query<T> query,
                                       long timeout)

withDefaultTimeout

public static <T> Query<T> withDefaultTimeout(Query<T> query,
                                              long defaultTimeout)