diff options
| author | Jacques Nadeau <jacques@apache.org> | 2014-02-17 12:06:06 -0800 |
|---|---|---|
| committer | Jacques Nadeau <jacques@apache.org> | 2014-03-03 23:22:17 -0800 |
| commit | 8b90cae3fe3c5aa48b7d82147452fda043305bd4 (patch) | |
| tree | 2e5249d6fd6f3d2adb58327a37604f98b9aad46d /exec/java-exec/src/main/java/org/apache/drill/exec/planner/PhysicalPlanReader.java | |
| parent | 2dfadc9d9945c347fded28ec90af5d0842f91853 (diff) | |
Integrate new SQL changes with Hive storage engine, moving to automatic file detection. Rename storage engine to storage plugin. Separate storage plugins from format plugins, updating Parquet and JSON to format engines. Refactor distribution logic and enable use within JSON format and all EasyFormatPlugins.
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/planner/PhysicalPlanReader.java')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/planner/PhysicalPlanReader.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/PhysicalPlanReader.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/PhysicalPlanReader.java index e270b7980..a1001631e 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/PhysicalPlanReader.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/PhysicalPlanReader.java @@ -37,7 +37,7 @@ import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectReader; import com.fasterxml.jackson.databind.module.SimpleModule; import org.apache.drill.exec.server.DrillbitContext; -import org.apache.drill.exec.store.StorageEngineRegistry; +import org.apache.drill.exec.store.StoragePluginRegistry; public class PhysicalPlanReader { static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(PhysicalPlanReader.class); @@ -48,7 +48,7 @@ public class PhysicalPlanReader { private final ObjectReader logicalPlanReader; public PhysicalPlanReader(DrillConfig config, ObjectMapper mapper, final DrillbitEndpoint endpoint, - final StorageEngineRegistry engineRegistry) { + final StoragePluginRegistry engineRegistry) { // Endpoint serializer/deserializer. SimpleModule deserModule = new SimpleModule("PhysicalOperatorModule") // @@ -61,7 +61,7 @@ public class PhysicalPlanReader { mapper.registerModule(deserModule); mapper.registerSubtypes(PhysicalOperatorUtil.getSubTypes(config)); InjectableValues injectables = new InjectableValues.Std() // - .addValue(StorageEngineRegistry.class, engineRegistry) // + .addValue(StoragePluginRegistry.class, engineRegistry) // .addValue(DrillbitEndpoint.class, endpoint); // this.mapper = mapper; |