diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageFormatPlugin.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageFormatPlugin.java | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageFormatPlugin.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageFormatPlugin.java index 15ea1b462..048aa8230 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageFormatPlugin.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/image/ImageFormatPlugin.java @@ -22,7 +22,6 @@ import java.io.IOException; import java.util.Collections; import java.util.List; -import org.apache.drill.common.exceptions.ExecutionSetupException; import org.apache.drill.common.expression.SchemaPath; import org.apache.drill.common.logical.StoragePluginConfig; import org.apache.drill.exec.ops.FragmentContext; @@ -57,11 +56,9 @@ public class ImageFormatPlugin extends EasyFormatPlugin<ImageFormatConfig> { @Override public RecordReader getRecordReader(FragmentContext context, DrillFileSystem dfs, FileWork fileWork, - List<SchemaPath> columns, String userName) throws ExecutionSetupException { - return new ImageRecordReader(context, dfs, fileWork.getPath(), - ((ImageFormatConfig)formatConfig).hasFileSystemMetadata(), - ((ImageFormatConfig)formatConfig).isDescriptive(), - ((ImageFormatConfig)formatConfig).getTimeZone()); + List<SchemaPath> columns, String userName) { + return new ImageRecordReader(context, dfs, fileWork.getPath(), formatConfig.hasFileSystemMetadata(), + formatConfig.isDescriptive(), formatConfig.getTimeZone()); } @Override |