diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasySubScan.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasySubScan.java | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasySubScan.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasySubScan.java index 0dbae1e40..fbb3f475c 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasySubScan.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/easy/EasySubScan.java @@ -17,7 +17,6 @@ */ package org.apache.drill.exec.store.dfs.easy; -import java.io.IOException; import java.util.List; import org.apache.drill.common.exceptions.ExecutionSetupException; @@ -34,6 +33,7 @@ import com.fasterxml.jackson.annotation.JsonIgnore; import com.fasterxml.jackson.annotation.JsonProperty; import com.fasterxml.jackson.annotation.JsonTypeName; import org.apache.drill.shaded.guava.com.google.common.base.Preconditions; +import org.apache.hadoop.fs.Path; @JsonTypeName("fs-sub-scan") public class EasySubScan extends AbstractSubScan{ @@ -42,18 +42,18 @@ public class EasySubScan extends AbstractSubScan{ private final List<FileWorkImpl> files; private final EasyFormatPlugin<?> formatPlugin; private final List<SchemaPath> columns; - private String selectionRoot; + private Path selectionRoot; @JsonCreator public EasySubScan( @JsonProperty("userName") String userName, - @JsonProperty("files") List<FileWorkImpl> files, // - @JsonProperty("storage") StoragePluginConfig storageConfig, // - @JsonProperty("format") FormatPluginConfig formatConfig, // - @JacksonInject StoragePluginRegistry engineRegistry, // - @JsonProperty("columns") List<SchemaPath> columns, // - @JsonProperty("selectionRoot") String selectionRoot - ) throws IOException, ExecutionSetupException { + @JsonProperty("files") List<FileWorkImpl> files, + @JsonProperty("storage") StoragePluginConfig storageConfig, + @JsonProperty("format") FormatPluginConfig formatConfig, + @JacksonInject StoragePluginRegistry engineRegistry, + @JsonProperty("columns") List<SchemaPath> columns, + @JsonProperty("selectionRoot") Path selectionRoot + ) throws ExecutionSetupException { super(userName); this.formatPlugin = (EasyFormatPlugin<?>) engineRegistry.getFormatPlugin(storageConfig, formatConfig); Preconditions.checkNotNull(this.formatPlugin); @@ -63,7 +63,7 @@ public class EasySubScan extends AbstractSubScan{ } public EasySubScan(String userName, List<FileWorkImpl> files, EasyFormatPlugin<?> plugin, List<SchemaPath> columns, - String selectionRoot){ + Path selectionRoot){ super(userName); this.formatPlugin = plugin; this.files = files; @@ -72,7 +72,7 @@ public class EasySubScan extends AbstractSubScan{ } @JsonProperty - public String getSelectionRoot() { + public Path getSelectionRoot() { return selectionRoot; } |