org.apache.ignite.internal.processors.hadoop

Class HadoopSplitWrapper

java.lang.Object

org.apache.ignite.hadoop.HadoopInputSplit

org.apache.ignite.internal.processors.hadoop.HadoopSplitWrapper

All Implemented Interfaces:

Externalizable, Serializable

public class HadoopSplitWrapper
extends HadoopInputSplit

The wrapper for native hadoop input splits. Warning!! This class must not depend on any Hadoop classes directly or indirectly.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.ignite.hadoop.HadoopInputSplit

hosts

Constructor Summary

Constructors

Constructor and Description
HadoopSplitWrapper() Creates new split wrapper.
HadoopSplitWrapper(int id, String clsName, byte[] bytes, String[] hosts) Creates new split wrapper.

Method Summary

Modifier and Type	Method and Description
byte[]	bytes()
String	className()
boolean	equals(Object o)
int	hashCode()
void	readExternal(ObjectInput in)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class org.apache.ignite.hadoop.HadoopInputSplit

hosts

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

HadoopSplitWrapper

public HadoopSplitWrapper()

Creates new split wrapper.

HadoopSplitWrapper

public HadoopSplitWrapper(int id,
                          String clsName,
                          byte[] bytes,
                          String[] hosts)

Creates new split wrapper.

Parameters:

id - Split ID.

clsName - Class name.

bytes - Serialized class.

hosts - Hosts where split is located.

Method Detail

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Throws:

IOException

className

public String className()

Returns:

Class name.

bytes

public byte[] bytes()

Returns:

Class bytes.

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Throws:

IOException

ClassNotFoundException

equals

public boolean equals(Object o)

Specified by:

equals in class HadoopInputSplit

hashCode

public int hashCode()

Specified by:

hashCode in class HadoopInputSplit

toString

public String toString()

Overrides:

toString in class Object