Modifier and Type | Method and Description |
---|---|
Stream<Column> |
DruidResponseParser.buildSchemaColumns(DruidAggregationQuery<?> druidQuery)
Produce the schema-defining columns for a given druid query.
|
Modifier and Type | Method and Description |
---|---|
ResultSetSchema |
ResultSetSchema.withAddColumn(Column column)
Create a new result set with an additional final column.
|
Constructor and Description |
---|
ResultSetSchema(Granularity granularity,
Iterable<Column> columns)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected Set<Column> |
PhysicalTableDefinition.buildColumns(DimensionDictionary dimensionDictionary)
Helper method for sub-classes to convert dimension configs into dimension columns and create metric columns.
|
Modifier and Type | Class and Description |
---|---|
class |
DimensionColumn
Result DimensionColumn definition.
|
class |
LogicalDimensionColumn
Deprecated.
in favor of DimensionColumn which stores name as api name now
|
Modifier and Type | Class and Description |
---|---|
class |
LogicalMetricColumn
LogicalMetricColumn.
|
class |
MetricColumn
Metric.
|
class |
MetricColumnWithValueType
The class which contains an information of metric value type.
|
Modifier and Type | Method and Description |
---|---|
default Stream<Column> |
DruidAggregationQuery.buildSchemaColumns()
Produce the schema-defining columns for a given druid query.
|
Modifier and Type | Method and Description |
---|---|
default <T extends Column> |
Schema.getColumn(String name,
Class<T> columnClass)
Given a column type and name, return the column of the expected type.
|
default <T extends Column> |
Schema.getColumns(Class<T> columnClass)
Getter for set of columns by sub-type.
|
Modifier and Type | Method and Description |
---|---|
Map<Column,SimplifiedIntervalList> |
BasePhysicalTable.getAllAvailableIntervals() |
Map<Column,SimplifiedIntervalList> |
PhysicalTable.getAllAvailableIntervals()
Getter for all the available intervals for the corresponding columns configured on the table.
|
Map<Column,SimplifiedIntervalList> |
ConstrainedTable.getAllAvailableIntervals() |
LinkedHashSet<Column> |
BaseSchema.getColumns() |
Set<Column> |
Schema.getColumns()
Get all the columns underlying this Schema.
|
default Set<Column> |
PhysicalTable.getColumns()
Deprecated.
In favor of getting the columns directly from the schema
|
default Map<Column,SimplifiedIntervalList> |
PhysicalTable.mapToSchemaAvailability(Map<String,SimplifiedIntervalList> rawIntervals,
PhysicalTableSchema schema)
Map availabilities in schema-less columns to a
Column keyed availability map for a given table. |
Constructor and Description |
---|
BaseCompositePhysicalTable(TableName name,
ZonedTimeGrain timeGrain,
Set<Column> columns,
Set<? extends PhysicalTable> physicalTables,
Map<String,String> logicalToPhysicalColumnNames,
Availability availability)
Constructor.
|
BasePhysicalTable(TableName name,
ZonedTimeGrain timeGrain,
Iterable<Column> columns,
Map<String,String> logicalToPhysicalColumnNames,
Availability availability)
Create a physical table.
|
BaseSchema(Granularity granularity,
Iterable<Column> columns)
Constructor.
|
MetricUnionCompositeTable(TableName name,
ZonedTimeGrain timeGrain,
Set<Column> columns,
Set<ConfigPhysicalTable> physicalTables,
Map<String,String> logicalToPhysicalColumnNames,
Map<Availability,Set<String>> availabilitiesToMetricNames)
Constructor.
|
PartitionCompositeTable(TableName name,
ZonedTimeGrain timeGrain,
Set<Column> columns,
Map<String,String> logicalToPhysicalColumnNames,
Map<ConfigPhysicalTable,DataSourceFilter> availabilityFilters)
Constructor.
|
PermissivePhysicalTable(TableName name,
ZonedTimeGrain timeGrain,
Set<Column> columns,
Map<String,String> logicalToPhysicalColumnNames,
DataSourceMetadataService metadataService)
Create a permissive physical table.
|
PermissivePhysicalTable(TableName name,
ZonedTimeGrain timeGrain,
Set<Column> columns,
Map<String,String> logicalToPhysicalColumnNames,
PermissiveAvailability availability)
Create a permissive physical table.
|
PhysicalTableSchema(ZonedTimeGrain timeGrain,
Iterable<Column> columns,
Map<String,String> logicalToPhysicalColumnNames)
Constructor.
|
SingleDataSourcePhysicalTable(TableName name,
ZonedTimeGrain timeGrain,
Iterable<Column> columns,
Map<String,String> logicalToPhysicalColumnNames,
BaseMetadataAvailability availability)
Constructor.
|
SqlPhysicalTable(TableName name,
ZonedTimeGrain timeGrain,
Iterable<Column> columns,
Map<String,String> logicalToPhysicalColumnNames,
Availability availability,
String schemaName,
String timestampColumn)
Create a physical table.
|
StrictPhysicalTable(TableName name,
ZonedTimeGrain timeGrain,
Set<Column> columns,
Map<String,String> logicalToPhysicalColumnNames,
DataSourceMetadataService metadataService)
Create a strict physical table.
|
StrictPhysicalTable(TableName name,
ZonedTimeGrain timeGrain,
Set<Column> columns,
Map<String,String> logicalToPhysicalColumnNames,
StrictAvailability availability)
Create a strict physical table with the availability on this table built externally.
|
ZonedSchema(Granularity granularity,
org.joda.time.DateTimeZone dateTimeZone,
Iterable<Column> columns)
Deprecated.
Constructor.
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.