Skip to content

Commit

Permalink
fix ut
Browse files Browse the repository at this point in the history
  • Loading branch information
morningman committed Sep 14, 2024
1 parent 17e68a6 commit 0d8fcd8
Showing 1 changed file with 16 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -18,11 +18,15 @@
package org.apache.doris.nereids.rules.analysis;

import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.Database;
import org.apache.doris.catalog.DatabaseIf;
import org.apache.doris.catalog.Env;
import org.apache.doris.catalog.KeysType;
import org.apache.doris.catalog.OlapTable;
import org.apache.doris.catalog.PartitionInfo;
import org.apache.doris.catalog.RandomDistributionInfo;
import org.apache.doris.catalog.Type;
import org.apache.doris.datasource.CatalogIf;
import org.apache.doris.nereids.analyzer.UnboundRelation;
import org.apache.doris.nereids.pattern.GeneratedPlanPatterns;
import org.apache.doris.nereids.rules.RulePromise;
Expand Down Expand Up @@ -98,6 +102,13 @@ public void bindExternalRelation() {
new Column("name", Type.VARCHAR)
);

Database database = new Database(10000, "external_db") {
@Override
public CatalogIf getCatalog() {
return Env.getCurrentInternalCatalog();
}
};

OlapTable externalOlapTable = new OlapTable(1, tableName, externalTableColumns, KeysType.DUP_KEYS,
new PartitionInfo(), new RandomDistributionInfo(10)) {
@Override
Expand All @@ -109,6 +120,11 @@ public List<Column> getBaseSchema(boolean full) {
public boolean hasDeleteSign() {
return false;
}

@Override
public DatabaseIf getDatabase() {
return database;
}
};

CustomTableResolver customTableResolver = qualifiedTable -> {
Expand Down

0 comments on commit 0d8fcd8

Please sign in to comment.