diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/metadata/Metadata_V2.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/metadata/Metadata_V2.java | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/metadata/Metadata_V2.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/metadata/Metadata_V2.java index 7eddc1279..a78fca4bf 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/metadata/Metadata_V2.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/metadata/Metadata_V2.java @@ -28,6 +28,7 @@ import com.fasterxml.jackson.databind.JsonDeserializer; import com.fasterxml.jackson.databind.JsonSerializer; import com.fasterxml.jackson.databind.KeyDeserializer; import com.fasterxml.jackson.databind.SerializerProvider; +import org.apache.hadoop.fs.Path; import org.apache.parquet.io.api.Binary; import org.apache.parquet.schema.OriginalType; import org.apache.parquet.schema.PrimitiveType; @@ -59,7 +60,7 @@ public class Metadata_V2 { @JsonProperty public ConcurrentHashMap<ColumnTypeMetadata_v2.Key, ColumnTypeMetadata_v2> columnTypeInfo; @JsonProperty List<ParquetFileMetadata_v2> files; - @JsonProperty List<String> directories; + @JsonProperty List<Path> directories; @JsonProperty String drillVersion; public ParquetTableMetadata_v2() { @@ -71,7 +72,7 @@ public class Metadata_V2 { } public ParquetTableMetadata_v2(String metadataVersion, ParquetTableMetadataBase parquetTable, - List<ParquetFileMetadata_v2> files, List<String> directories, String drillVersion) { + List<ParquetFileMetadata_v2> files, List<Path> directories, String drillVersion) { this.metadataVersion = metadataVersion; this.files = files; this.directories = directories; @@ -79,7 +80,7 @@ public class Metadata_V2 { this.drillVersion = drillVersion; } - public ParquetTableMetadata_v2(String metadataVersion, List<ParquetFileMetadata_v2> files, List<String> directories, + public ParquetTableMetadata_v2(String metadataVersion, List<ParquetFileMetadata_v2> files, List<Path> directories, ConcurrentHashMap<ColumnTypeMetadata_v2.Key, ColumnTypeMetadata_v2> columnTypeInfo, String drillVersion) { this.metadataVersion = metadataVersion; this.files = files; @@ -93,7 +94,7 @@ public class Metadata_V2 { } @JsonIgnore - @Override public List<String> getDirectories() { + @Override public List<Path> getDirectories() { return directories; } @@ -152,14 +153,14 @@ public class Metadata_V2 { * Struct which contains the metadata for a single parquet file */ public static class ParquetFileMetadata_v2 extends ParquetFileMetadata { - @JsonProperty public String path; + @JsonProperty public Path path; @JsonProperty public Long length; @JsonProperty public List<RowGroupMetadata_v2> rowGroups; public ParquetFileMetadata_v2() { } - public ParquetFileMetadata_v2(String path, Long length, List<RowGroupMetadata_v2> rowGroups) { + public ParquetFileMetadata_v2(Path path, Long length, List<RowGroupMetadata_v2> rowGroups) { this.path = path; this.length = length; this.rowGroups = rowGroups; @@ -169,7 +170,7 @@ public class Metadata_V2 { return String.format("path: %s rowGroups: %s", path, rowGroups); } - @JsonIgnore @Override public String getPath() { + @JsonIgnore @Override public Path getPath() { return path; } |