com.nhncorp.neptune.util.matrix
Class MatrixInputFormat

java.lang.Object
  com.nhncorp.neptune.util.matrix.MatrixInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat, org.apache.hadoop.mapred.JobConfigurable

public class MatrixInputFormat
extends java.lang.Object
implements org.apache.hadoop.mapred.InputFormat, org.apache.hadoop.mapred.JobConfigurable

Field Summary

static java.lang.String	MATRIX_INPUT_COLUMN
static java.lang.String	MATRIX_INPUT_TABLE
static java.lang.String	MATRIX_RESULT_COLUMN
static java.lang.String	MATRIX_RESULT_SPARSE
static java.lang.String	MATRIX_RESULT_TABLE
static java.lang.String	MATRIX_TARGET_COLUMN
static java.lang.String	MATRIX_TARGET_SPARSE
static java.lang.String	MATRIX_TARGET_TABLE

Constructor Summary

MatrixInputFormat()

Method Summary

void	configure(org.apache.hadoop.mapred.JobConf job)
org.apache.hadoop.mapred.RecordReader	getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter)
org.apache.hadoop.mapred.InputSplit[]	getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits)
void	validateInput(org.apache.hadoop.mapred.JobConf job)

Methods inherited from class java.lang.Object

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

Field Detail

MATRIX_INPUT_TABLE

public static final java.lang.String MATRIX_INPUT_TABLE

See Also:

Constant Field Values

MATRIX_INPUT_COLUMN

public static final java.lang.String MATRIX_INPUT_COLUMN

See Also:

Constant Field Values

MATRIX_TARGET_TABLE

public static final java.lang.String MATRIX_TARGET_TABLE

See Also:

Constant Field Values

MATRIX_TARGET_COLUMN

public static final java.lang.String MATRIX_TARGET_COLUMN

See Also:

Constant Field Values

MATRIX_TARGET_SPARSE

public static final java.lang.String MATRIX_TARGET_SPARSE

See Also:

Constant Field Values

MATRIX_RESULT_TABLE

public static final java.lang.String MATRIX_RESULT_TABLE

See Also:

Constant Field Values

MATRIX_RESULT_COLUMN

public static final java.lang.String MATRIX_RESULT_COLUMN

See Also:

Constant Field Values

MATRIX_RESULT_SPARSE

public static final java.lang.String MATRIX_RESULT_SPARSE

See Also:

Constant Field Values

Constructor Detail

MatrixInputFormat

public MatrixInputFormat()
                  throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getRecordReader

public org.apache.hadoop.mapred.RecordReader getRecordReader(org.apache.hadoop.mapred.InputSplit split,
                                                             org.apache.hadoop.mapred.JobConf job,
                                                             org.apache.hadoop.mapred.Reporter reporter)
                                                      throws java.io.IOException

Specified by:

getRecordReader in interface org.apache.hadoop.mapred.InputFormat

Throws:

java.io.IOException

getSplits

public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job,
                                                       int numSplits)
                                                throws java.io.IOException

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat

Throws:

java.io.IOException

configure

public void configure(org.apache.hadoop.mapred.JobConf job)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

validateInput

public void validateInput(org.apache.hadoop.mapred.JobConf job)
                   throws java.io.IOException

Specified by:

validateInput in interface org.apache.hadoop.mapred.InputFormat

Throws:

java.io.IOException