org.apache.ignite.internal.processors.hadoop.impl.v1

Class HadoopV1Splitter

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Splitter

public class HadoopV1Splitter
extends Object

Hadoop API v1 splitter.

Constructor Summary

Constructors

Constructor and Description
HadoopV1Splitter()

Method Summary

Modifier and Type	Method and Description
static HadoopFileBlock	readFileBlock(String clsName, FSDataInputStream in, String[] hosts)
static Collection<HadoopInputSplit>	splitJob(JobConf jobConf)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopV1Splitter

public HadoopV1Splitter()

Method Detail

splitJob

public static Collection<HadoopInputSplit> splitJob(JobConf jobConf)
                                             throws IgniteCheckedException

Parameters:

jobConf - Job configuration.

Returns:

Collection of mapped splits.

Throws:

IgniteCheckedException - If mapping failed.

readFileBlock

@Nullable
public static HadoopFileBlock readFileBlock(String clsName,
                                                      FSDataInputStream in,
                                                      @Nullable
                                                      String[] hosts)
                                               throws IgniteCheckedException

Parameters:

clsName - Input split class name.

in - Input stream.

hosts - Optional hosts.

Returns:

File block or null if it is not a FileSplit instance.

Throws:

IgniteCheckedException - If failed.