set ParquetStorageEngineConfig so that it is included in json of physical plan.
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/1206bce3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/1206bce3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/1206bce3 Branch: refs/heads/master Commit: 1206bce3fecc75cd4d3018c079f98581e3719f41 Parents: 1212cc7 Author: Steven Phillips <[email protected]> Authored: Mon Sep 2 23:48:03 2013 -0700 Committer: Steven Phillips <[email protected]> Committed: Tue Sep 3 17:34:23 2013 -0700 ---------------------------------------------------------------------- .../org/apache/drill/exec/store/parquet/ParquetGroupScan.java | 1 + .../apache/drill/exec/store/parquet/ParquetStorageEngine.java | 7 ++++++- 2 files changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/1206bce3/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScan.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScan.java b/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScan.java index 2dc5102..f0f3481 100644 --- a/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScan.java +++ b/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetGroupScan.java @@ -112,6 +112,7 @@ public class ParquetGroupScan extends AbstractGroupScan { public ParquetGroupScan(ArrayList<ReadEntryWithPath> entries, ParquetStorageEngine storageEngine, FieldReference ref) throws IOException { this.storageEngine = storageEngine; + this.engineConfig = storageEngine.getEngineConfig(); this.availableEndpoints = storageEngine.getContext().getBits(); this.fs = storageEngine.getFileSystem(); this.entries = entries; http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/1206bce3/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetStorageEngine.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetStorageEngine.java b/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetStorageEngine.java index 1629aba..939545e 100644 --- a/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetStorageEngine.java +++ b/sandbox/prototype/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/ParquetStorageEngine.java @@ -60,12 +60,13 @@ public class ParquetStorageEngine extends AbstractStorageEngine{ private CodecFactoryExposer codecFactoryExposer; final ParquetMetadata footer; private final ParquetSchemaProvider schemaProvider; + private final ParquetStorageEngineConfig engineConfig; public ParquetStorageEngine(ParquetStorageEngineConfig configuration, DrillbitContext context){ this.context = context; this.schemaProvider = new ParquetSchemaProvider(configuration, context.getConfig()); codecFactoryExposer = new CodecFactoryExposer(schemaProvider.conf); - + this.engineConfig = configuration; this.footer = null; } @@ -79,6 +80,10 @@ public class ParquetStorageEngine extends AbstractStorageEngine{ return schemaProvider.fs; } + public ParquetStorageEngineConfig getEngineConfig() { + return engineConfig; + } + public DrillbitContext getContext() { return this.context; }
