import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
public RelNode toRel(
        RelOptTable.ToRelContext context,
        RelOptTable relOptTable) {
    return new JavaRules.EnumerableTableAccessRel(
            context.getCluster(),
            context.getCluster().traitSetOf(EnumerableConvention.INSTANCE),
            relOptTable,
            getElementType());
}
 

import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
public RelNode toRel(
    RelOptTable.ToRelContext context,
    RelOptTable relOptTable) {
  return new JavaRules.EnumerableTableAccessRel(
      context.getCluster(),
      context.getCluster().traitSetOf(EnumerableConvention.INSTANCE),
      relOptTable,
      (Class) getElementType());
}
 

import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
public RelNode toRel(
    RelOptTable.ToRelContext context,
    RelOptTable relOptTable) {
  // Request all fields.
  final int fieldCount = relOptTable.getRowType().getFieldCount();
  final int[] fields = CsvEnumerator.identityList(fieldCount);
  return new CsvTableScan(context.getCluster(), relOptTable, this, fields);
}
 

import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
@Override
public Result implement(EnumerableRelImplementor implementor, Prefer pref) {
    Result result = null;
    if (this.hasSubQuery) {
        result = super.implement(implementor, pref);
    } else {
        PhysType physType = PhysTypeImpl.of(implementor.getTypeFactory(), getRowType(), pref.preferArray());

        RelOptTable factTable = context.firstTableScan.getTable();
        result = implementor.result(physType, Blocks.toBlock(Expressions.call(factTable.getExpression(OLAPTable.class), "executeIndexQuery", implementor.getRootExpression(), Expressions.constant(context.id))));
    }

    return result;
}
 

import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
public OLAPTableScan(RelOptCluster cluster, RelOptTable table, OLAPTable olapTable, int[] fields) {
    super(cluster, cluster.traitSetOf(OLAPRel.CONVENTION), table);
    this.olapTable = olapTable;
    this.fields = fields;
    this.tableName = olapTable.getTableName();
    this.rowType = getRowType();
}
 

import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
@Override
public RelNode toRel(ToRelContext context, RelOptTable relOptTable) {

	return new TableScanner(context.getCluster(), context.getCluster()
			.traitSetOf(CosmosRelNode.CONVENTION), relOptTable, this,
			relOptTable.getRowType().getFieldNames());
}
 

import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
public RelNode toRel(RelOptTable.ToRelContext context, RelOptTable relOptTable) {
    return new JavaRules.EnumerableTableAccessRel(context.getCluster(),
        context.getCluster().traitSetOf(EnumerableConvention.INSTANCE),
        relOptTable, (Class) getElementType());
}
 

import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
@Override
public RelNode toRel(ToRelContext context, RelOptTable relOptTable) {
    int fieldCount = relOptTable.getRowType().getFieldCount();
    int[] fields = identityList(fieldCount);
    return new OLAPTableScan(context.getCluster(), relOptTable, this, fields);
}
 

import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
public StratosphereDataSource(RelOptCluster cluster,RelOptTable table, Operator op) {
	super(cluster,cluster.traitSetOf(StratosphereRel.CONVENTION), table);
	Preconditions.checkArgument(getConvention() == CONVENTION);
	Preconditions.checkNotNull(op);
	this.op = op;
}
 

import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
@Override
public RelNode toRel(ToRelContext context, RelOptTable relOptTable) {
	return new StratosphereDataSource(context.getCluster(), relOptTable, fileSrcOperator);
}
 

import org.eigenbase.relopt.RelOptTable; //导入依赖的package包/类
public TableScanner(RelOptCluster cluster, RelTraitSet traitSet, RelOptTable table, DataTable<?> resultTable, List<String> fieldList) {
  super(cluster, traitSet, table);

  this.resultTable = resultTable;
  this.fieldList = fieldList;
}