com.twitter.maple.tap

Class TupleMemoryInputFormat.TupleInputSplit

java.lang.Object

com.twitter.maple.tap.TupleMemoryInputFormat.TupleInputSplit

All Implemented Interfaces:

org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit

Enclosing class:

TupleMemoryInputFormat

public static class TupleMemoryInputFormat.TupleInputSplit
extends java.lang.Object
implements org.apache.hadoop.mapred.InputSplit

Field Summary

Fields

Modifier and Type	Field and Description
int	numTuples

Constructor Summary

Constructors

Constructor and Description
TupleInputSplit()
TupleInputSplit(int numTuples)

Method Summary

Modifier and Type	Method and Description
long	getLength()
java.lang.String[]	getLocations()
void	readFields(java.io.DataInput di)
void	write(java.io.DataOutput d)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

numTuples

public int numTuples

Constructor Detail

TupleInputSplit

public TupleInputSplit()

TupleInputSplit

public TupleInputSplit(int numTuples)

Method Detail

getLength

public long getLength()
               throws java.io.IOException

Specified by:

getLength in interface org.apache.hadoop.mapred.InputSplit

Throws:

java.io.IOException

getLocations

public java.lang.String[] getLocations()
                                throws java.io.IOException

Specified by:

getLocations in interface org.apache.hadoop.mapred.InputSplit

Throws:

java.io.IOException

write

public void write(java.io.DataOutput d)
           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 di)
                throws java.io.IOException

Specified by:

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

Throws:

java.io.IOException