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 |
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<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
int concurrencyHint,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories)
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) |
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() |
ValueType |
LongTopNColumnSelectorStrategy.getValueType() |
ValueType |
FloatTopNColumnSelectorStrategy.getValueType() |
Modifier and Type | Method and Description |
---|---|
ValueType |
StringDimensionIndexer.getValueType() |
ValueType |
LongDimensionIndexer.getValueType() |
ValueType |
FloatDimensionIndexer.getValueType() |
ValueType |
DimensionIndexer.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 |
IndexedLongsGenericColumn.getType() |
ValueType |
IndexedFloatsGenericColumn.getType() |
ValueType |
GenericColumn.getType() |
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 |
---|---|
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 | Method and Description |
---|---|
DimensionSpec |
RowExtraction.toDimensionSpec(RowSignature rowSignature,
String outputName,
ValueType outputType) |
Modifier and Type | Method and Description |
---|---|
static ValueType |
Calcites.getValueTypeForSqlTypeName(org.apache.calcite.sql.type.SqlTypeName sqlTypeName) |
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–2017. All rights reserved.