public class ParquetInputSplit
extends org.apache.hadoop.mapreduce.lib.input.FileSplit
implements org.apache.hadoop.io.Writable
Constructor and Description |
---|
ParquetInputSplit()
Writables must have a parameterless constructor
|
ParquetInputSplit(org.apache.hadoop.fs.Path path,
long start,
long length,
String[] hosts,
List<BlockMetaData> blocks,
String requestedSchema,
String fileSchema,
Map<String,String> extraMetadata,
Map<String,String> readSupportMetadata)
|
Modifier and Type | Method and Description |
---|---|
List<BlockMetaData> |
getBlocks() |
Map<String,String> |
getExtraMetadata() |
String |
getFileSchema() |
Map<String,String> |
getReadSupportMetadata() |
String |
getRequestedSchema() |
void |
readFields(DataInput in) |
String |
toString() |
void |
write(DataOutput out) |
public ParquetInputSplit()
public ParquetInputSplit(org.apache.hadoop.fs.Path path, long start, long length, String[] hosts, List<BlockMetaData> blocks, String requestedSchema, String fileSchema, Map<String,String> extraMetadata, Map<String,String> readSupportMetadata)
path
- the path to the filestart
- the offset of the block in the filelength
- the size of the block in the filehosts
- the hosts where this block can be foundblocks
- the block meta data (Columns locations)schema
- the file schemareadSupportClass
- the class used to materialize recordsrequestedSchema
- the requested schema for materializationfileSchema
- the schema of the fileextraMetadata
- the app specific meta data in the filereadSupportMetadata
- the read support specific metadatapublic List<BlockMetaData> getBlocks()
public String getRequestedSchema()
public String getFileSchema()
public Map<String,String> getExtraMetadata()
public Map<String,String> getReadSupportMetadata()
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
readFields
in class org.apache.hadoop.mapreduce.lib.input.FileSplit
IOException
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
write
in class org.apache.hadoop.mapreduce.lib.input.FileSplit
IOException
public String toString()
toString
in class org.apache.hadoop.mapreduce.lib.input.FileSplit
Copyright © 2015. All rights reserved.