Modifier and Type | Method and Description |
---|---|
protected PhysicalTable |
BaseTableLoader.loadPhysicalTable(PhysicalTableDefinition definition,
Set<FieldName> metricNames,
ResourceDictionaries dictionaries)
Deprecated.
use buildPhysicalTableWithDependency instead, which also supports building table with dependencies
|
Modifier and Type | Method and Description |
---|---|
default SimplifiedIntervalList |
VolatileIntervalsService.getVolatileIntervals(DruidAggregationQuery<?> query,
PhysicalTable factSource)
Deprecated.
Exists solely for backwards compatibility.
VolatileIntervalsService.getVolatileIntervals(Granularity, List, PhysicalTable) should be used instead |
SimplifiedIntervalList |
VolatileIntervalsService.getVolatileIntervals(Granularity granularity,
List<org.joda.time.Interval> intervals,
PhysicalTable factSource)
Retrieve a simplified sublist of the given intervals aligned to the specified time buckets and that are
partially or fully volatile.
|
SimplifiedIntervalList |
DefaultingVolatileIntervalsService.getVolatileIntervals(Granularity granularity,
List<org.joda.time.Interval> intervals,
PhysicalTable factSource) |
Constructor and Description |
---|
DefaultingVolatileIntervalsService(DefaultingDictionary<PhysicalTable,VolatileIntervalsFunction> intervalsFunctions)
Deprecated.
Simply use maps and default values
|
DefaultingVolatileIntervalsService(VolatileIntervalsFunction defaultIntervalsFunction,
Map<PhysicalTable,VolatileIntervalsFunction> intervalsFunctions)
Use a default function with overrides for particular tables.
|
Modifier and Type | Method and Description |
---|---|
void |
DataSourceMetadataService.update(PhysicalTable table,
DataSourceMetadata metadata)
Deprecated.
Pass the DataSourceName directly, rather than via the PhysicalTable
|
Modifier and Type | Interface and Description |
---|---|
interface |
ConfigPhysicalTable
This interface limits direct access to availability to tables intended for use during the configuration lifecycle.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseCompositePhysicalTable
An implementation of BasePhysicalTable that contains multiple tables.
|
class |
BasePhysicalTable
Base implementation of physical table that are shared across various types of physical tables.
|
class |
ConstrainedTable
Constrained table caches the results of applying a
DataSourceConstraint to a Physical table's availability. |
class |
MetricUnionCompositeTable
An implementation of
PhysicalTable backed by MetricUnionAvailability . |
class |
PartitionCompositeTable
An implementation of
PhysicalTable backed by PartitionAvailability availability. |
class |
PermissivePhysicalTable
A sibling of strict physical table, but with permissive availability.
|
class |
SingleDataSourcePhysicalTable
A Physical Table that should be backed by a Metadata-based Availability that has only a single data source.
|
class |
SqlPhysicalTable
An implementation of
BasePhysicalTable specific for Sql Backed datasources. |
class |
StrictPhysicalTable
An implementation of Physical table that is backed by a single fact table and has intersect availability.
|
Modifier and Type | Method and Description |
---|---|
PhysicalTable |
ConstrainedTable.getSourceTable() |
Modifier and Type | Method and Description |
---|---|
Set<PhysicalTable> |
TableGroup.getPhysicalTables()
Getter for set of physical tables.
|
Constructor and Description |
---|
BaseCompositePhysicalTable(TableName name,
ZonedTimeGrain timeGrain,
Set<Column> columns,
Set<? extends PhysicalTable> physicalTables,
Map<String,String> logicalToPhysicalColumnNames,
Availability availability)
Constructor.
|
TableGroup(LinkedHashSet<PhysicalTable> tables,
Set<ApiMetricName> apiMetricNames)
Deprecated.
TableGroup should not be deriving its dimensions from physical tables, because a logical table may
only surface a subset of the dimensions on its PhysicalTable
|
TableGroup(LinkedHashSet<PhysicalTable> tables,
Set<ApiMetricName> apiMetricNames,
Set<Dimension> dimensions)
Builds a TableGroup.
|
Modifier and Type | Method and Description |
---|---|
boolean |
IsTableAligned.test(PhysicalTable table)
Test for alignment between a table and a criteria.
|
boolean |
IsTableStartAlignedWithIntervals.test(PhysicalTable table)
Test whether table aligns with the interval collection supplied.
|
Modifier and Type | Method and Description |
---|---|
PhysicalTable |
BasePhysicalTableResolver.resolve(Collection<PhysicalTable> candidateTables,
QueryPlanningConstraint requestConstraint) |
PhysicalTable |
PhysicalTableResolver.resolve(Collection<PhysicalTable> candidateTables,
QueryPlanningConstraint requestConstraint)
Choose the best fit Physical Table from a table group.
|
Modifier and Type | Method and Description |
---|---|
Set<PhysicalTable> |
BasePhysicalTableResolver.filter(Collection<PhysicalTable> candidateTables,
List<PhysicalTableMatcher> matchers)
Filter a list of tables through each matcher using a list of matchers sequentially.
|
Set<PhysicalTable> |
BasePhysicalTableResolver.filter(Collection<PhysicalTable> candidateTables,
QueryPlanningConstraint requestConstraint)
Filter to a set of tables matching the rules of this resolver.
|
abstract BinaryOperator<PhysicalTable> |
BasePhysicalTableResolver.getBetterTableOperator(QueryPlanningConstraint requestConstraint)
Create a binary operator which returns the 'better' of two physical table.
|
BinaryOperator<PhysicalTable> |
DefaultPhysicalTableResolver.getBetterTableOperator(QueryPlanningConstraint requestConstraint) |
default Set<PhysicalTable> |
PhysicalTableMatcher.matchNotEmpty(Stream<PhysicalTable> tables)
Run matches on each physical table in the stream, filtering down to matching tables.
|
Modifier and Type | Method and Description |
---|---|
int |
GranularityComparator.compare(PhysicalTable table1,
PhysicalTable table2)
Compare two physical tables identifying which one has fewer time buckets.
|
int |
PartialTimeComparator.compare(PhysicalTable left,
PhysicalTable right)
Compare two Physical Tables based on how much missing time they have.
|
int |
DimensionCardinalityComparator.compare(PhysicalTable table1,
PhysicalTable table2)
Compare two Physical Tables based on their number of dimensions.
|
int |
VolatileTimeComparator.compare(PhysicalTable left,
PhysicalTable right)
Performs a comparison based on how much data each table has within their volatile intervals.
|
boolean |
AggregatableDimensionsMatcher.test(PhysicalTable table) |
boolean |
SchemaPhysicalTableMatcher.test(PhysicalTable table) |
boolean |
PhysicalTableMatcher.test(PhysicalTable table)
Determines whether this table matches a requirement.
|
boolean |
TimeAlignmentPhysicalTableMatcher.test(PhysicalTable table) |
static DataSourceConstraint |
DataSourceConstraint.unconstrained(PhysicalTable table)
Build a constraint which should not filter away any part of a given table.
|
Modifier and Type | Method and Description |
---|---|
Set<PhysicalTable> |
BasePhysicalTableResolver.filter(Collection<PhysicalTable> candidateTables,
List<PhysicalTableMatcher> matchers)
Filter a list of tables through each matcher using a list of matchers sequentially.
|
Set<PhysicalTable> |
BasePhysicalTableResolver.filter(Collection<PhysicalTable> candidateTables,
QueryPlanningConstraint requestConstraint)
Filter to a set of tables matching the rules of this resolver.
|
default Set<PhysicalTable> |
PhysicalTableMatcher.matchNotEmpty(Stream<PhysicalTable> tables)
Run matches on each physical table in the stream, filtering down to matching tables.
|
PhysicalTable |
BasePhysicalTableResolver.resolve(Collection<PhysicalTable> candidateTables,
QueryPlanningConstraint requestConstraint) |
PhysicalTable |
PhysicalTableResolver.resolve(Collection<PhysicalTable> candidateTables,
QueryPlanningConstraint requestConstraint)
Choose the best fit Physical Table from a table group.
|
Modifier and Type | Method and Description |
---|---|
static Set<String> |
TableUtils.getColumnNames(DataApiRequest request,
DruidAggregationQuery<?> query,
PhysicalTable table)
Deprecated.
in favor of getColumnNames(DataApiRequest, DruidAggregationQuery) returning dimension api name
|
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.