org.kepler.stratosphere.io.input

Class TokenInputSplit

java.lang.Object

eu.stratosphere.core.io.GenericInputSplit

org.kepler.stratosphere.io.input.TokenInputSplit

All Implemented Interfaces:

eu.stratosphere.core.io.InputSplit, eu.stratosphere.core.io.IOReadableWritable

public class TokenInputSplit
extends eu.stratosphere.core.io.GenericInputSplit

An input split for Ptolemy tokens.

Author:

Daniel Crawl

Field Summary

Fields inherited from class eu.stratosphere.core.io.GenericInputSplit

number

Constructor Summary

Constructors

Constructor and Description
TokenInputSplit() A constructor that takes no arguments is required.
TokenInputSplit(int i, Token token) Create a new TokenInputSplit.

Method Summary

Modifier and Type	Method and Description
Token	getToken() Get the token.
void	read(java.io.DataInput in) Read a token from the input stream.
java.lang.String	toString() Get a string representation of this split.
void	write(java.io.DataOutput out) Write the token to the output stream.

Methods inherited from class eu.stratosphere.core.io.GenericInputSplit

getSplitNumber

Methods inherited from class java.lang.Object

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

Constructor Detail

TokenInputSplit

public TokenInputSplit()

A constructor that takes no arguments is required.

TokenInputSplit

public TokenInputSplit(int i,
                       Token token)

Create a new TokenInputSplit.

Parameters:

i - the split number.

token - the token.

Method Detail

getToken

public Token getToken()

Get the token.

write

public void write(java.io.DataOutput out)
           throws java.io.IOException

Write the token to the output stream.

Specified by:

write in interface eu.stratosphere.core.io.IOReadableWritable

Overrides:

write in class eu.stratosphere.core.io.GenericInputSplit

Throws:

java.io.IOException

read

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

Read a token from the input stream.

Specified by:

read in interface eu.stratosphere.core.io.IOReadableWritable

Overrides:

read in class eu.stratosphere.core.io.GenericInputSplit

Throws:

java.io.IOException

toString

public java.lang.String toString()

Get a string representation of this split.

Overrides:

toString in class eu.stratosphere.core.io.GenericInputSplit