Skip to content

Commit cdc03d3

Browse files
committed
PR comments
1 parent b169246 commit cdc03d3

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sql/LiveCatalogResolver.java

+5
Original file line numberDiff line numberDiff line change
@@ -37,13 +37,17 @@
3737
import org.apache.druid.sql.calcite.table.DatasourceTable.PhysicalDatasourceMetadata;
3838
import org.apache.druid.sql.calcite.table.DruidTable;
3939

40+
import javax.annotation.Nullable;
4041
import javax.inject.Inject;
4142

4243
import java.util.HashMap;
4344
import java.util.HashSet;
4445
import java.util.Map;
4546
import java.util.Set;
4647

48+
/**
49+
* A catalog resolver that uses the catalog stored on the Druid coordinator.
50+
*/
4751
public class LiveCatalogResolver implements CatalogResolver
4852
{
4953
private final MetadataCatalog catalog;
@@ -54,6 +58,7 @@ public LiveCatalogResolver(final MetadataCatalog catalog)
5458
this.catalog = catalog;
5559
}
5660

61+
@Nullable
5762
private DatasourceFacade datasourceSpec(String name)
5863
{
5964
TableId tableId = TableId.datasource(name);

0 commit comments

Comments
 (0)