Repository: incubator-drill Updated Branches: refs/heads/master fdcedf972 -> 730950622
DRILL-1599: Drill FileSystemPlugin need getOptimizerRules() method to get optimizer rules from format plugin Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/73095062 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/73095062 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/73095062 Branch: refs/heads/master Commit: 7309506226cd5540590eda542a104cf3590dd436 Parents: fdcedf9 Author: Anbang Xu <[email protected]> Authored: Tue Oct 28 17:44:03 2014 -0700 Committer: Aditya Kishore <[email protected]> Committed: Tue Oct 28 18:30:57 2014 -0700 ---------------------------------------------------------------------- .../drill/exec/store/dfs/FileSystemPlugin.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/73095062/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/FileSystemPlugin.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/FileSystemPlugin.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/FileSystemPlugin.java index 0449db3..db6c0c7 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/FileSystemPlugin.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/FileSystemPlugin.java @@ -20,6 +20,7 @@ package org.apache.drill.exec.store.dfs; import java.io.IOException; import java.util.List; import java.util.Map; +import java.util.Set; import net.hydromatic.optiq.SchemaPlus; @@ -34,11 +35,14 @@ import org.apache.drill.exec.server.DrillbitContext; import org.apache.drill.exec.store.AbstractStoragePlugin; import org.apache.drill.exec.store.ClassPathFileSystem; import org.apache.drill.exec.store.LocalSyncableFileSystem; +import org.apache.drill.exec.store.StoragePluginOptimizerRule; import org.apache.drill.exec.store.dfs.shim.DrillFileSystem; import org.apache.drill.exec.store.dfs.shim.FileSystemCreator; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; +import com.google.common.collect.ImmutableSet; +import com.google.common.collect.ImmutableSet.Builder; import com.google.common.collect.Lists; import com.google.common.collect.Maps; @@ -137,4 +141,17 @@ public class FileSystemPlugin extends AbstractStoragePlugin{ } } + @Override + public Set<StoragePluginOptimizerRule> getOptimizerRules() { + Builder<StoragePluginOptimizerRule> setBuilder = ImmutableSet.builder(); + for(FormatPlugin plugin : this.formatPluginsByName.values()){ + Set<StoragePluginOptimizerRule> rules = plugin.getOptimizerRules(); + if(rules != null && rules.size() > 0){ + setBuilder.addAll(rules); + } + } + return setBuilder.build(); + } + + }
