本文整理汇总了Java中org.apache.calcite.schema.Statistic类的典型用法代码示例。如果您正苦于以下问题:Java Statistic类的具体用法?Java Statistic怎么用?Java Statistic使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Statistic类属于org.apache.calcite.schema包,在下文中一共展示了Statistic类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
public Statistic getStatistic() {
return new Statistic() {
public Double getRowCount() {
return table.rowCount;
}
public boolean isKey(ImmutableBitSet columns) {
return table.isKey(columns);
}
public List<RelReferentialConstraint> getReferentialConstraints() {
return table.getReferentialConstraints();
}
public List<RelCollation> getCollations() {
return table.collationList;
}
public RelDistribution getDistribution() {
return table.getDistribution();
}
};
}
开发者ID:apache,项目名称:calcite,代码行数:24,代码来源:MockCatalogReader.java
示例2: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
return new StatisticImpl() {
@Override
public Double getRowCount() {
return (double) dataset.getReadDefinition().getScanStats().getRecordCount();
}
};
}
开发者ID:dremio,项目名称:dremio-oss,代码行数:10,代码来源:NamespaceTable.java
示例3: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
return new StatisticImpl() {
@Override
public Double getRowCount() {
return (double) datasetAccessor.getDataset().getReadDefinition().getScanStats().getRecordCount();
}
};
}
开发者ID:dremio,项目名称:dremio-oss,代码行数:10,代码来源:MaterializedDatasetTable.java
示例4: buildStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
private Statistic buildStatistic() {
if (stats != null || primaryKey == -1) {
return stats;
}
Direction dir = primaryKeyMonotonicity == INCREASING ? ASCENDING : DESCENDING;
RelFieldCollation collation = new RelFieldCollation(primaryKey, dir, NullDirection.UNSPECIFIED);
return Statistics.of(fields.size(), ImmutableList.of(ImmutableBitSet.of(primaryKey)),
ImmutableList.of(RelCollations.of(collation)));
}
开发者ID:hortonworks,项目名称:streamline,代码行数:10,代码来源:CompilerUtil.java
示例5: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
int counter = 0;
for (IThreadStack threadStack : getThreadStacks()) {
counter += threadStack.getStackFrames().length;
}
return Statistics.of(counter, ImmutableList.of(ImmutableBitSet.of(0, 1)));
}
开发者ID:vlsi,项目名称:mat-calcite-plugin,代码行数:9,代码来源:SnapshotThreadStacksTable.java
示例6: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
public Statistic getStatistic() {
final List<ImmutableBitSet> keys = Lists.newArrayList();
final Content content = supplier.get();
for (Ord<Column> ord : Ord.zip(content.columns)) {
if (ord.e.cardinality == content.size) {
keys.add(ImmutableBitSet.of(ord.i));
}
}
return Statistics.of(content.size, keys, content.collations);
}
开发者ID:apache,项目名称:calcite,代码行数:11,代码来源:ArrayTable.java
示例7: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
return Statistics.UNKNOWN;
}
开发者ID:skhalifa,项目名称:QDrill,代码行数:5,代码来源:DrillTable.java
示例8: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
return Statistics.of(tableManager.getStats().getTablesize(),
keys);
}
开发者ID:diennea,项目名称:herddb,代码行数:6,代码来源:CalcitePlanner.java
示例9: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
return Statistics.of(desc.getItemCount(), ImmutableList.of(), ImmutableList.of());
}
开发者ID:fineoio,项目名称:drill-dynamo-adapter,代码行数:5,代码来源:DrillDynamoTable.java
示例10: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
/**
* Not used {@link Statistic} to optimize the plan.
*/
@Override
public Statistic getStatistic() {
return Statistics.UNKNOWN;
}
开发者ID:apache,项目名称:beam,代码行数:8,代码来源:BeamSqlEnv.java
示例11: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
return drillTable.getStatistic();
}
开发者ID:axbaretto,项目名称:drill,代码行数:5,代码来源:DrillTranslatableTable.java
示例12: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
throw new UnsupportedOperationException(
"Statistic was not retrieved when this table had been being requested");
}
开发者ID:axbaretto,项目名称:drill,代码行数:6,代码来源:HiveDatabaseSchema.java
示例13: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic()
{
return Statistics.of(100d, ImmutableList.<ImmutableBitSet>of(), RelCollations.createSingleton(0));
}
开发者ID:apache,项目名称:apex-malhar,代码行数:6,代码来源:ApexSQLTable.java
示例14: statistics
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
public TableBuilderInfo statistics(Statistic stats) {
this.stats = stats;
return this;
}
开发者ID:hortonworks,项目名称:streamline,代码行数:5,代码来源:CompilerUtil.java
示例15: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
public Statistic getStatistic() {
return Statistics.of(0d, ImmutableList.<ImmutableBitSet>of());
}
开发者ID:qubole,项目名称:quark,代码行数:4,代码来源:QuarkViewTable.java
示例16: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
List<ImmutableBitSet> keys = new ArrayList<ImmutableBitSet>();
return Statistics.of(100, keys);
}
开发者ID:apache,项目名称:kylin,代码行数:6,代码来源:OLAPTable.java
示例17: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
return Statistics.of(references.size(), unique ? UNIQUE_KEYS_STATISTICS : NON_UNIQUE_KEYS_STATISTICS);
}
开发者ID:vlsi,项目名称:mat-calcite-plugin,代码行数:5,代码来源:TableFunctions.java
示例18: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
List<ImmutableBitSet> uniqueKeys = ImmutableList.of(ImmutableBitSet.of(0));
return Statistics.of(classesList.getTotalObjects(), uniqueKeys);
}
开发者ID:vlsi,项目名称:mat-calcite-plugin,代码行数:6,代码来源:InstanceIdsByClassTable.java
示例19: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override
public Statistic getStatistic() {
return Statistics.of(references.size(), NON_UNIQUE_KEYS_STATISTICS);
}
开发者ID:vlsi,项目名称:mat-calcite-plugin,代码行数:5,代码来源:OutboundReferencesTable.java
示例20: getStatistic
import org.apache.calcite.schema.Statistic; //导入依赖的package包/类
@Override public Statistic getStatistic() {
Bug.upgrade("add row count estimate to TpcdsTable, and use it");
Integer rowCount = TABLE_ROW_COUNTS.get(tpcdsTable.name);
assert rowCount != null : tpcdsTable.name;
return Statistics.of(rowCount, Collections.<ImmutableBitSet>emptyList());
}
开发者ID:apache,项目名称:calcite,代码行数:7,代码来源:TpcdsSchema.java
注:本文中的org.apache.calcite.schema.Statistic类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论