comments

apache · Nov 16, 2017 · 9a86032 · 9a86032
1 parent 435ee17
commit 9a86032
Showing 1 changed file with 0 additions and 14 deletions.
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/WorkspaceSchemaFactory.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/WorkspaceSchemaFactory.java
@@ -189,10 +189,6 @@ private Path getViewPath(String name) {
     return DotDrillType.VIEW.getPath(config.getLocation(), name);
   }
 
-  public WorkspaceSchema createSchema(List<String> parentSchemaPath, SchemaConfig schemaConfig) throws IOException {
-    return new WorkspaceSchema(parentSchemaPath, schemaName, schemaConfig);
-  }
-
   public WorkspaceSchema createSchema(List<String> parentSchemaPath, SchemaConfig schemaConfig, DrillFileSystem fs) throws IOException {
     if (!accessible(fs)) {
       return null;
@@ -408,13 +404,6 @@ public class WorkspaceSchema extends AbstractSchema implements ExpandingConcurre
     private final SchemaConfig schemaConfig;
     private DrillFileSystem fs;
 
-    public WorkspaceSchema(List<String> parentSchemaPath, String wsName, SchemaConfig schemaConfig) throws IOException {
-      super(parentSchemaPath, wsName);
-      this.schemaConfig = schemaConfig;
-      //we will create fs only when needed
-      //this.fs = ImpersonationUtil.createFileSystem(schemaConfig.getUserName(), fsConf);
-    }
-
     public WorkspaceSchema(List<String> parentSchemaPath, String wsName, SchemaConfig schemaConfig, DrillFileSystem fs) throws IOException {
       super(parentSchemaPath, wsName);
       this.schemaConfig = schemaConfig;
@@ -572,9 +561,6 @@ public boolean isMutable() {
     }
 
     public DrillFileSystem getFS() {
-      if (fs == null) {
-        fs = ImpersonationUtil.createFileSystem(schemaConfig.getUserName(), fsConf);
-      }
       return fs;
     }