org.apache.iceberg.mr.mapreduce

Class 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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String[]	ANYWHERE

Constructor Summary

Constructors

Constructor and Description
IcebergSplit()

Method Summary

Modifier and Type	Method and Description
long	getLength()
java.lang.String[]	getLocations()
IcebergSplit	icebergSplit()
void	readFields(java.io.DataInput in)
Table	table()
CombinedScanTask	task()
void	write(java.io.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

Field Detail

ANYWHERE

public static final java.lang.String[] ANYWHERE

Constructor Detail

IcebergSplit

public IcebergSplit()

Method Detail

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 java.lang.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(java.io.DataOutput out)
           throws java.io.IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

java.io.IOException

readFields

public void readFields(java.io.DataInput in)
                throws java.io.IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

java.io.IOException

table

public Table table()