IcebergSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

org.apache.iceberg.mr.mapreduce.IcebergSplit

All Implemented Interfaces:: org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit, IcebergSplitContainer

public class IcebergSplit extends org.apache.hadoop.mapreduce.InputSplit implements org.apache.hadoop.mapred.InputSplit, IcebergSplitContainer

Constructor Summary

Constructors

Constructor

Description

IcebergSplit()
Method Summary

Modifier and Type

Method

Description

long

getLength()

String[]

getLocations()

IcebergSplit

icebergSplit()

void

readFields(DataInput in)

Table

table()

CombinedScanTask

task()

void

write(DataOutput out)

Methods inherited from class org.apache.hadoop.mapreduce.InputSplit
getLocationInfo

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- IcebergSplit
  
  public IcebergSplit()
Method Details
- task
  
  public CombinedScanTask task()
- icebergSplit
  
  public IcebergSplit icebergSplit()
  
  Specified by:
  
  icebergSplit in interface IcebergSplitContainer
- getLength
  
  public long getLength()
  
  Specified by:
  
  getLength in interface org.apache.hadoop.mapred.InputSplit
  
  Specified by:
  
  getLength in class org.apache.hadoop.mapreduce.InputSplit
- getLocations
  
  public String[] getLocations()
  
  Specified by:
  
  getLocations in interface org.apache.hadoop.mapred.InputSplit
  
  Specified by:
  
  getLocations in class org.apache.hadoop.mapreduce.InputSplit
- write
  
  public void write(DataOutput out) throws IOException
  
  Specified by:
  
  write in interface org.apache.hadoop.io.Writable
  
  Throws:
  
  IOException
- readFields
  
  public void readFields(DataInput in) throws IOException
  
  Specified by:
  
  readFields in interface org.apache.hadoop.io.Writable
  
  Throws:
  
  IOException
- table
  
  public Table table()