Modifier and Type | Method and Description |
---|---|
ValueType |
BenchmarkColumnSchema.getType() |
Modifier and Type | Method and Description |
---|---|
static BenchmarkColumnSchema |
BenchmarkColumnSchema.makeContinuousUniform(String name,
ValueType type,
boolean isMetric,
int rowSize,
Double nullProbability,
double startDouble,
double endDouble) |
static BenchmarkColumnSchema |
BenchmarkColumnSchema.makeDiscreteUniform(String name,
ValueType type,
boolean isMetric,
int rowSize,
Double nullProbability,
int startInt,
int endInt) |
static BenchmarkColumnSchema |
BenchmarkColumnSchema.makeEnumerated(String name,
ValueType type,
boolean isMetric,
int rowSize,
Double nullProbability,
List<Object> enumeratedValues,
List<Double> enumeratedProbabilities) |
static BenchmarkColumnSchema |
BenchmarkColumnSchema.makeEnumeratedDiscreteUniform(String name,
ValueType type,
boolean isMetric,
int rowSize,
Double nullProbability,
List<Object> enumeratedValues) |
static BenchmarkColumnSchema |
BenchmarkColumnSchema.makeEnumeratedSequential(String name,
ValueType type,
boolean isMetric,
int rowSize,
Double nullProbability,
List<Object> enumeratedValues) |
static BenchmarkColumnSchema |
BenchmarkColumnSchema.makeEnumeratedZipf(String name,
ValueType type,
boolean isMetric,
int rowSize,
Double nullProbability,
List<Object> enumeratedValues,
Double zipfExponent) |
static BenchmarkColumnSchema |
BenchmarkColumnSchema.makeNormal(String name,
ValueType type,
boolean isMetric,
int rowSize,
Double nullProbability,
Double mean,
Double standardDeviation,
boolean useRounding) |
static BenchmarkColumnSchema |
BenchmarkColumnSchema.makeSequential(String name,
ValueType type,
boolean isMetric,
int rowSize,
Double nullProbability,
int startInt,
int endInt) |
static BenchmarkColumnSchema |
BenchmarkColumnSchema.makeZipf(String name,
ValueType type,
boolean isMetric,
int rowSize,
Double nullProbability,
int startInt,
int endInt,
Double zipfExponent) |
Modifier and Type | Method and Description |
---|---|
ValueType |
InputRowSerde.IndexSerdeTypeHelper.getType() |
ValueType |
InputRowSerde.StringIndexSerdeTypeHelper.getType() |
ValueType |
InputRowSerde.LongIndexSerdeTypeHelper.getType() |
ValueType |
InputRowSerde.FloatIndexSerdeTypeHelper.getType() |
ValueType |
InputRowSerde.DoubleIndexSerdeTypeHelper.getType() |
Modifier and Type | Method and Description |
---|---|
ValueType |
LookupDimensionSpec.getOutputType() |
ValueType |
ExtractionDimensionSpec.getOutputType() |
ValueType |
DimensionSpec.getOutputType() |
ValueType |
DefaultDimensionSpec.getOutputType() |
ValueType |
BaseFilteredDimensionSpec.getOutputType() |
Constructor and Description |
---|
DefaultDimensionSpec(String dimension,
String outputName,
ValueType outputType) |
ExtractionDimensionSpec(String dimension,
String outputName,
ValueType outputType,
ExtractionFn extractionFn) |
ExtractionDimensionSpec(String dimension,
String outputName,
ValueType outputType,
ExtractionFn extractionFn,
ExtractionFn dimExtractionFn) |
Modifier and Type | Method and Description |
---|---|
static Map<String,ValueType> |
GroupByQueryHelper.rowSignatureFor(GroupByQuery query)
Returns types for fields that will appear in the Rows output from "query".
|
Modifier and Type | Method and Description |
---|---|
static RowBasedColumnSelectorFactory |
RowBasedColumnSelectorFactory.create(com.google.common.base.Supplier<? extends Row> row,
Map<String,ValueType> rowSignature) |
static RowBasedColumnSelectorFactory |
RowBasedColumnSelectorFactory.create(ThreadLocal<? extends Row> row,
Map<String,ValueType> rowSignature) |
Modifier and Type | Method and Description |
---|---|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
int mergeBufferSize)
Create a single-threaded grouper and accumulator.
|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
int concurrencyHint,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
com.google.common.util.concurrent.ListeningExecutorService grouperSorter,
int priority,
boolean hasQueryTimeout,
long queryTimeoutAt,
int mergeBufferSize)
If isInputRaw is true, transformations such as timestamp truncation and extraction functions have not
been applied to the input rows yet, for example, in a nested query, if an extraction function is being
applied in the outer query to a field of the inner query.
|
static Sequence<Row> |
GroupByRowProcessor.process(Query queryParam,
Sequence<Row> rows,
Map<String,ValueType> rowSignature,
GroupByQueryConfig config,
GroupByQueryResource resource,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir,
int mergeBufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
OrHavingSpec.setRowSignature(Map<String,ValueType> rowSignature) |
void |
NotHavingSpec.setRowSignature(Map<String,ValueType> rowSignature) |
void |
HavingSpec.setRowSignature(Map<String,ValueType> rowSignature)
Informs this HavingSpec that rows passed to "eval" will have a certain signature.
|
void |
DimFilterHavingSpec.setRowSignature(Map<String,ValueType> rowSignature) |
void |
BaseHavingSpec.setRowSignature(Map<String,ValueType> rowSignature) |
void |
AndHavingSpec.setRowSignature(Map<String,ValueType> rowSignature) |
Modifier and Type | Method and Description |
---|---|
static com.google.common.base.Function<Object,Object> |
TopNMapFn.getValueTransformer(ValueType outputType) |
Modifier and Type | Method and Description |
---|---|
ValueType |
TopNColumnSelectorStrategy.getValueType() |
ValueType |
StringTopNColumnSelectorStrategy.getValueType() |
Modifier and Type | Method and Description |
---|---|
static List<ValueType> |
DimensionHandlerUtils.getValueTypesFromDimensionSpecs(List<DimensionSpec> dimSpecs) |
Modifier and Type | Method and Description |
---|---|
static ValueType |
ValueType.fromString(String name) |
ValueType |
ColumnCapabilitiesImpl.getType() |
ValueType |
ColumnCapabilities.getType() |
ValueType |
ColumnDescriptor.getValueType() |
static ValueType |
ValueType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ValueType[] |
ValueType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
ValueType.isNumeric(ValueType type) |
ColumnCapabilitiesImpl |
ColumnCapabilitiesImpl.setType(ValueType type) |
ColumnBuilder |
ColumnBuilder.setType(ValueType type) |
ColumnDescriptor.Builder |
ColumnDescriptor.Builder.setValueType(ValueType valueType) |
Constructor and Description |
---|
ColumnDescriptor(ValueType valueType,
boolean hasMultipleValues,
List<ColumnPartSerde> parts) |
Modifier and Type | Field and Description |
---|---|
static List<ValueType> |
Filters.FILTERABLE_TYPES |
Modifier and Type | Field and Description |
---|---|
static Map<Object,ValueType> |
IncrementalIndex.TYPE_MAP |
Modifier and Type | Method and Description |
---|---|
Transformer |
TransformSpec.toTransformer(Map<String,ValueType> rowSignature)
Create a
Transformer from this TransformSpec, taking advantage of the known signature of the rows
to be transformed. |
Modifier and Type | Method and Description |
---|---|
ValueType |
ExpressionVirtualColumn.getOutputType() |
Constructor and Description |
---|
ExpressionVirtualColumn(String name,
String expression,
ValueType outputType,
ExprMacroTable macroTable) |
Modifier and Type | Method and Description |
---|---|
ValueType |
DimensionExpression.getOutputType() |
Constructor and Description |
---|
DimensionExpression(String outputName,
DruidExpression expression,
ValueType outputType) |
Modifier and Type | Method and Description |
---|---|
static ExprType |
Expressions.exprTypeForValueType(ValueType valueType) |
DimensionSpec |
SimpleExtraction.toDimensionSpec(String outputName,
ValueType outputType) |
ExpressionVirtualColumn |
DruidExpression.toVirtualColumn(String name,
ValueType outputType,
ExprMacroTable macroTable) |
Modifier and Type | Method and Description |
---|---|
static ValueType |
Calcites.getValueTypeForSqlTypeName(org.apache.calcite.sql.type.SqlTypeName sqlTypeName) |
Modifier and Type | Method and Description |
---|---|
static StringComparator |
Calcites.getStringComparatorForValueType(ValueType valueType) |
Modifier and Type | Method and Description |
---|---|
ValueType |
RowSignature.getColumnType(String name) |
Modifier and Type | Method and Description |
---|---|
RowSignature.Builder |
RowSignature.Builder.add(String columnName,
ValueType columnType) |
Copyright © 2011–2018. All rights reserved.