Package org.apache.druid.query
Class QueryContexts
java.lang.Object
org.apache.druid.query.QueryContexts
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final booleanstatic final booleanstatic final CloneQueryModestatic final booleanstatic final booleanstatic final booleanstatic final booleanstatic final longstatic final booleanstatic final booleanstatic final booleanstatic final booleanstatic final booleanstatic final Stringstatic final booleanstatic final intstatic final intstatic final intstatic final booleanstatic final booleanstatic final booleanstatic final intstatic final booleanstatic final booleanstatic final Stringstatic final longstatic final intstatic final booleanstatic final booleanstatic final booleanstatic final booleanstatic final intstatic final QueryContexts.Vectorizestatic final QueryContexts.Vectorizestatic final Stringstatic final Stringstatic final StringContext parameter to enable/disable the extended filtered sum rewrite logic.static final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final longstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final Stringstatic final String -
Method Summary
Modifier and TypeMethodDescriptionstatic voidstatic BadQueryContextExceptionbadTypeException(String key, String expected, Object actual) static BadQueryContextExceptionbadValueException(String key, String expected, Object actual) static BooleangetAsBoolean(String key, Object value) static booleangetAsBoolean(String key, Object value, boolean defaultValue) Get the value of a context value as aboolean.static <E extends Enum<E>>
Estatic <E extends Enum<E>>
Estatic FloatgetAsFloat(String key, Object value) Get the value of a context value as anFloat.static floatgetAsFloat(String key, Object value, float defaultValue) static HumanReadableBytesgetAsHumanReadableBytes(String key, Object value, HumanReadableBytes defaultValue) static Integerstatic intGet the value of a context value as anint.static Longstatic longGet the value of a context value as anlong.static StringgetAsString(String key, Object value, String defaultValue) Insert, update or remove a single key to produce an overridden context.Insert or replace multiple keys to produce an overridden context.static booleanparseBoolean(Map<String, Object> context, String key, boolean defaultValue) static floatparseFloat(Map<String, Object> context, String key, float defaultValue) static intstatic longstatic StringparseString(Map<String, Object> context, String key) static String
-
Field Details
-
FINALIZE_KEY
- See Also:
-
PRIORITY_KEY
- See Also:
-
LANE_KEY
- See Also:
-
TIMEOUT_KEY
- See Also:
-
PER_SEGMENT_TIMEOUT_KEY
- See Also:
-
MAX_SCATTER_GATHER_BYTES_KEY
- See Also:
-
MAX_QUEUED_BYTES_KEY
- See Also:
-
DEFAULT_TIMEOUT_KEY
- See Also:
-
BROKER_PARALLEL_MERGE_KEY
- See Also:
-
BROKER_PARALLEL_MERGE_INITIAL_YIELD_ROWS_KEY
- See Also:
-
BROKER_PARALLEL_MERGE_SMALL_BATCH_ROWS_KEY
- See Also:
-
BROKER_PARALLELISM
- See Also:
-
VECTORIZE_KEY
- See Also:
-
VECTORIZE_VIRTUAL_COLUMNS_KEY
- See Also:
-
VECTOR_SIZE_KEY
- See Also:
-
MAX_SUBQUERY_ROWS_KEY
- See Also:
-
MAX_SUBQUERY_BYTES_KEY
- See Also:
-
USE_NESTED_FOR_UNKNOWN_TYPE_IN_SUBQUERY
- See Also:
-
JOIN_FILTER_PUSH_DOWN_KEY
- See Also:
-
JOIN_FILTER_REWRITE_ENABLE_KEY
- See Also:
-
JOIN_FILTER_REWRITE_VALUE_COLUMN_FILTERS_ENABLE_KEY
- See Also:
-
REWRITE_JOIN_TO_FILTER_ENABLE_KEY
- See Also:
-
JOIN_FILTER_REWRITE_MAX_SIZE_KEY
- See Also:
-
MAX_NUMERIC_IN_FILTERS
- See Also:
-
CURSOR_AUTO_ARRANGE_FILTERS
- See Also:
-
CLONE_QUERY_MODE
- See Also:
-
SQL_JOIN_LEFT_SCAN_DIRECT
- See Also:
-
USE_FILTER_CNF_KEY
- See Also:
-
NUM_RETRIES_ON_MISSING_SEGMENTS_KEY
- See Also:
-
RETURN_PARTIAL_RESULTS_KEY
- See Also:
-
USE_CACHE_KEY
- See Also:
-
SECONDARY_PARTITION_PRUNING_KEY
- See Also:
-
ENABLE_DEBUG
- See Also:
-
BY_SEGMENT_KEY
- See Also:
-
BROKER_SERVICE_NAME
- See Also:
-
IN_SUB_QUERY_THRESHOLD_KEY
- See Also:
-
IN_FUNCTION_THRESHOLD
- See Also:
-
IN_FUNCTION_EXPR_THRESHOLD
- See Also:
-
TIME_BOUNDARY_PLANNING_KEY
- See Also:
-
POPULATE_CACHE_KEY
- See Also:
-
POPULATE_RESULT_LEVEL_CACHE_KEY
- See Also:
-
USE_RESULT_LEVEL_CACHE_KEY
- See Also:
-
SERIALIZE_DATE_TIME_AS_LONG_KEY
- See Also:
-
SERIALIZE_DATE_TIME_AS_LONG_INNER_KEY
- See Also:
-
UNCOVERED_INTERVALS_LIMIT_KEY
- See Also:
-
MIN_TOP_N_THRESHOLD
- See Also:
-
CATALOG_VALIDATION_ENABLED
- See Also:
-
ENGINE
- See Also:
-
TOPN_USE_MULTI_PASS_POOLED_QUERY_GRANULARITY
- See Also:
-
EXTENDED_FILTERED_SUM_REWRITE_ENABLED
Context parameter to enable/disable the extended filtered sum rewrite logic. Controls the rewrite of:SUM(CASE WHEN COND THEN COL1 ELSE 0 END) to SUM(COL1) FILTER (COND)managed by. Defaults to true for performance, but may produce incorrect results when the condition never matches (expected 0). This is for testing and can be removed once a correct and high-performance rewrite is implemented.invalid reference
DruidAggregateCaseToFilterRule- See Also:
-
NO_PROJECTIONS
- See Also:
-
FORCE_PROJECTION
- See Also:
-
USE_PROJECTION
- See Also:
-
QUERY_RESOURCE_ID
- See Also:
-
CTX_SQL_QUERY_ID
- See Also:
-
CTX_SQL_STRINGIFY_ARRAYS
- See Also:
-
CTX_DART_QUERY_ID
- See Also:
-
CTX_FULL_REPORT
- See Also:
-
CTX_EXECUTION_MODE
- See Also:
-
CTX_NATIVE_QUERY_SQL_PLANNING_MODE
- See Also:
-
NATIVE_QUERY_SQL_PLANNING_MODE_COUPLED
- See Also:
-
NATIVE_QUERY_SQL_PLANNING_MODE_DECOUPLED
- See Also:
-
REALTIME_SEGMENTS_ONLY
- See Also:
-
DEFAULT_REALTIME_SEGMENTS_ONLY
public static final boolean DEFAULT_REALTIME_SEGMENTS_ONLY- See Also:
-
CTX_PREPLANNED
- See Also:
-
DEFAULT_PREPLANNED
public static final boolean DEFAULT_PREPLANNED- See Also:
-
DEFAULT_BY_SEGMENT
public static final boolean DEFAULT_BY_SEGMENT- See Also:
-
DEFAULT_POPULATE_CACHE
public static final boolean DEFAULT_POPULATE_CACHE- See Also:
-
DEFAULT_USE_CACHE
public static final boolean DEFAULT_USE_CACHE- See Also:
-
DEFAULT_POPULATE_RESULTLEVEL_CACHE
public static final boolean DEFAULT_POPULATE_RESULTLEVEL_CACHE- See Also:
-
DEFAULT_USE_RESULTLEVEL_CACHE
public static final boolean DEFAULT_USE_RESULTLEVEL_CACHE- See Also:
-
DEFAULT_VECTORIZE
-
DEFAULT_VECTORIZE_VIRTUAL_COLUMN
-
DEFAULT_VECTOR_SIZE
public static final int DEFAULT_VECTOR_SIZE- See Also:
-
DEFAULT_PRIORITY
public static final int DEFAULT_PRIORITY- See Also:
-
DEFAULT_UNCOVERED_INTERVALS_LIMIT
public static final int DEFAULT_UNCOVERED_INTERVALS_LIMIT- See Also:
-
DEFAULT_TIMEOUT_MILLIS
public static final long DEFAULT_TIMEOUT_MILLIS -
NO_TIMEOUT
public static final long NO_TIMEOUT- See Also:
-
DEFAULT_ENABLE_PARALLEL_MERGE
public static final boolean DEFAULT_ENABLE_PARALLEL_MERGE- See Also:
-
DEFAULT_ENABLE_JOIN_FILTER_PUSH_DOWN
public static final boolean DEFAULT_ENABLE_JOIN_FILTER_PUSH_DOWN- See Also:
-
DEFAULT_ENABLE_JOIN_FILTER_REWRITE
public static final boolean DEFAULT_ENABLE_JOIN_FILTER_REWRITE- See Also:
-
DEFAULT_ENABLE_JOIN_FILTER_REWRITE_VALUE_COLUMN_FILTERS
public static final boolean DEFAULT_ENABLE_JOIN_FILTER_REWRITE_VALUE_COLUMN_FILTERS- See Also:
-
DEFAULT_CLONE_QUERY_MODE
-
DEFAULT_ENGINE
- See Also:
-
DEFAULT_ENABLE_REWRITE_JOIN_TO_FILTER
public static final boolean DEFAULT_ENABLE_REWRITE_JOIN_TO_FILTER- See Also:
-
DEFAULT_ENABLE_JOIN_FILTER_REWRITE_MAX_SIZE
public static final long DEFAULT_ENABLE_JOIN_FILTER_REWRITE_MAX_SIZE- See Also:
-
DEFAULT_ENABLE_SQL_JOIN_LEFT_SCAN_DIRECT
public static final boolean DEFAULT_ENABLE_SQL_JOIN_LEFT_SCAN_DIRECT- See Also:
-
DEFAULT_USE_FILTER_CNF
public static final boolean DEFAULT_USE_FILTER_CNF- See Also:
-
DEFAULT_SECONDARY_PARTITION_PRUNING
public static final boolean DEFAULT_SECONDARY_PARTITION_PRUNING- See Also:
-
DEFAULT_ENABLE_DEBUG
public static final boolean DEFAULT_ENABLE_DEBUG- See Also:
-
DEFAULT_IN_SUB_QUERY_THRESHOLD
public static final int DEFAULT_IN_SUB_QUERY_THRESHOLD- See Also:
-
DEFAULT_IN_FUNCTION_THRESHOLD
public static final int DEFAULT_IN_FUNCTION_THRESHOLD- See Also:
-
DEFAULT_IN_FUNCTION_EXPR_THRESHOLD
public static final int DEFAULT_IN_FUNCTION_EXPR_THRESHOLD- See Also:
-
DEFAULT_ENABLE_TIME_BOUNDARY_PLANNING
public static final boolean DEFAULT_ENABLE_TIME_BOUNDARY_PLANNING- See Also:
-
DEFAULT_CATALOG_VALIDATION_ENABLED
public static final boolean DEFAULT_CATALOG_VALIDATION_ENABLED- See Also:
-
DEFAULT_USE_NESTED_FOR_UNKNOWN_TYPE_IN_SUBQUERY
public static final boolean DEFAULT_USE_NESTED_FOR_UNKNOWN_TYPE_IN_SUBQUERY- See Also:
-
DEFAULT_EXTENDED_FILTERED_SUM_REWRITE_ENABLED
public static final boolean DEFAULT_EXTENDED_FILTERED_SUM_REWRITE_ENABLED- See Also:
-
DEFAULT_CTX_FULL_REPORT
public static final boolean DEFAULT_CTX_FULL_REPORT- See Also:
-
-
Method Details
-
parseLong
-
parseInt
-
parseString
-
parseBoolean
-
parseString
-
parseFloat
-
getAsString
-
getAsBoolean
-
getAsBoolean
Get the value of a context value as aboolean. The value is expected to benull, a string or aBooleanobject. -
getAsInt
-
getAsInt
Get the value of a context value as anint. The value is expected to benull, a string or aNumberobject. -
getAsLong
-
getAsLong
Get the value of a context value as anlong. The value is expected to benull, a string or aNumberobject. -
getAsFloat
Get the value of a context value as anFloat. The value is expected to benull, a string or aNumberobject. -
getAsFloat
-
getAsHumanReadableBytes
public static HumanReadableBytes getAsHumanReadableBytes(String key, Object value, HumanReadableBytes defaultValue) -
override
Insert, update or remove a single key to produce an overridden context. Leaves the original context unchanged.- Parameters:
context- context to overridekey- key to insert, update or removevalue- ifnull, remove the key. Otherwise, insert or replace the key.- Returns:
- a new context map
-
override
Insert or replace multiple keys to produce an overridden context. Leaves the original context unchanged.- Parameters:
context- context to overrideoverrides- map of values to insert or replace- Returns:
- a new context map
-
getAsEnum
-
getAsEnum
-
badValueException
public static BadQueryContextException badValueException(String key, String expected, Object actual) -
badTypeException
-
addDefaults
-