WIP

Author: cgivre

exec/java-exec/src/main/java/org/apache/drill/exec/ops/QueryContext.java

@@ -319,7 +319,7 @@ public RemoteFunctionRegistry getRemoteFunctionRegistry() {
   }
 
   public DaffodilSchemaRegistry getDaffodilSchemaRegistry() {
-    return drillbitContext.getDaffodilSchemaRegistry();
+    return drillbitContext.getDaffodilSchemaProvider();
   }
 
   @Override

exec/java-exec/src/main/java/org/apache/drill/exec/schema/daffodil/README.md

@@ -0,0 +1,3 @@
+# Daffodil Schema Providers
+The classes in this package implement a persistent store for Apache Daffodil schemata.  These files create a store which Drill will use to track schemata.  When the files are installed via SQL commands, the store will copy them from the staging directory and propagate them to every node in the Drill cluster.
+

exec/java-exec/src/main/java/org/apache/drill/exec/server/DrillbitContext.java

@@ -42,7 +42,7 @@
 import org.apache.drill.exec.rpc.user.UserServer;
 import org.apache.drill.exec.rpc.user.UserServer.BitToUserConnection;
 import org.apache.drill.exec.rpc.user.UserServer.BitToUserConnectionConfig;
-import org.apache.drill.exec.schema.daffodil.DaffodilSchemaRegistry;
+import org.apache.drill.exec.schema.daffodil.DaffodilSchemaProvider;
 import org.apache.drill.exec.server.options.SystemOptionManager;
 import org.apache.drill.exec.store.SchemaFactory;
 import org.apache.drill.exec.store.StoragePluginRegistry;
@@ -83,7 +83,7 @@ public class DrillbitContext implements AutoCloseable {
   private ResourceManager resourceManager;
   private final MetastoreRegistry metastoreRegistry;
   private final DrillCounters counters;
-  private final DaffodilSchemaRegistry daffodilSchemaRegistry;
+  private final DaffodilSchemaProvider daffodilSchemaProvider;
 
   public DrillbitContext(
       DrillbitEndpoint endpoint,
@@ -136,7 +136,7 @@ public DrillbitContext(
     this.oAuthTokenProvider = new OAuthTokenProvider(this);
 
     // TODO Start here and complete the initialization process
-    this.daffodilSchemaRegistry = new DaffodilSchemaRegistry(config, classpathScan, systemOptions);
+    this.daffodilSchemaProvider = new DaffodilSchemaProvider(config, classpathScan, systemOptions);
 
     this.counters = DrillCounters.getInstance();
   }
@@ -289,8 +289,8 @@ public RemoteFunctionRegistry getRemoteFunctionRegistry() {
     return functionRegistry.getRemoteFunctionRegistry();
   }
 
-  public DaffodilSchemaRegistry getDaffodilSchemaRegistry() {
-    return daffodilSchemaRegistry;
+  public DaffodilSchemaProvider getDaffodilSchemaProvider() {
+    return daffodilSchemaProvider;
   }
 
   /**
@@ -327,6 +327,7 @@ public void close() throws Exception {
     getMetastoreRegistry().close();
     getAliasRegistryProvider().close();
     getOauthTokenProvider().close();
+    getDaffodilSchemaProvider().close();
   }
 
   public ResourceManager getResourceManager() {