public class HCatSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit
Constructor and Description |
---|
HCatSplit()
Instantiates a new hcat split.
|
HCatSplit(PartInfo partitionInfo,
org.apache.hadoop.mapred.InputSplit baseMapRedSplit)
Instantiates a new hcat split.
|
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.InputSplit |
getBaseSplit()
Gets the underlying InputSplit.
|
HCatSchema |
getDataSchema()
Gets the data schema.
|
long |
getLength() |
String[] |
getLocations() |
PartInfo |
getPartitionInfo()
Gets the partition info.
|
HCatSchema |
getTableSchema()
Gets the table schema.
|
void |
readFields(DataInput input) |
void |
write(DataOutput output) |
public HCatSplit()
public HCatSplit(PartInfo partitionInfo, org.apache.hadoop.mapred.InputSplit baseMapRedSplit)
partitionInfo
- the partition infobaseMapRedSplit
- the base mapred splitpublic PartInfo getPartitionInfo()
public org.apache.hadoop.mapred.InputSplit getBaseSplit()
public HCatSchema getDataSchema()
public HCatSchema getTableSchema()
public long getLength()
getLength
in interface org.apache.hadoop.mapred.InputSplit
getLength
in class org.apache.hadoop.mapreduce.InputSplit
public String[] getLocations()
getLocations
in interface org.apache.hadoop.mapred.InputSplit
getLocations
in class org.apache.hadoop.mapreduce.InputSplit
public void readFields(DataInput input) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
IOException
public void write(DataOutput output) throws IOException
write
in interface org.apache.hadoop.io.Writable
IOException
Copyright © 2022 The Apache Software Foundation. All rights reserved.