Package org.apache.iceberg.mr.hive
Class HiveIcebergSplit
java.lang.Object
org.apache.hadoop.mapreduce.InputSplit
org.apache.hadoop.mapred.FileSplit
org.apache.iceberg.mr.hive.HiveIcebergSplit
- All Implemented Interfaces:
org.apache.hadoop.io.Writable
,org.apache.hadoop.mapred.InputSplit
,org.apache.hadoop.mapred.InputSplitWithLocationInfo
,IcebergSplitContainer
public class HiveIcebergSplit
extends org.apache.hadoop.mapred.FileSplit
implements IcebergSplitContainer
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionlong
String[]
org.apache.hadoop.fs.Path
getPath()
long
getStart()
void
readFields
(DataInput in) void
write
(DataOutput out) Methods inherited from class org.apache.hadoop.mapred.FileSplit
getLocationInfo, toString
-
Constructor Details
-
HiveIcebergSplit
public HiveIcebergSplit()
-
-
Method Details
-
icebergSplit
- Specified by:
icebergSplit
in interfaceIcebergSplitContainer
-
getLength
public long getLength()- Specified by:
getLength
in interfaceorg.apache.hadoop.mapred.InputSplit
- Overrides:
getLength
in classorg.apache.hadoop.mapred.FileSplit
-
getLocations
- Specified by:
getLocations
in interfaceorg.apache.hadoop.mapred.InputSplit
- Overrides:
getLocations
in classorg.apache.hadoop.mapred.FileSplit
-
getPath
public org.apache.hadoop.fs.Path getPath()- Overrides:
getPath
in classorg.apache.hadoop.mapred.FileSplit
-
getStart
public long getStart()- Overrides:
getStart
in classorg.apache.hadoop.mapred.FileSplit
-
write
- Specified by:
write
in interfaceorg.apache.hadoop.io.Writable
- Overrides:
write
in classorg.apache.hadoop.mapred.FileSplit
- Throws:
IOException
-
readFields
- Specified by:
readFields
in interfaceorg.apache.hadoop.io.Writable
- Overrides:
readFields
in classorg.apache.hadoop.mapred.FileSplit
- Throws:
IOException
-