com.nhncorp.neptune.parallel.hadoop
Class DefaultTabletInputFormat

java.lang.Object
  com.nhncorp.neptune.parallel.hadoop.AbstractTabletInputFormat
      com.nhncorp.neptune.parallel.hadoop.DefaultTabletInputFormat

All Implemented Interfaces:

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

public class DefaultTabletInputFormat
extends AbstractTabletInputFormat

기본적으로 제공되는 Tablet InputFormat isRowScan 모드는 true를 반환한다. map()의 파라미터 중 key, value에는 각각 Row.Key, Row를 전달한다.

Author:

nhn

Nested Class Summary

Nested classes/interfaces inherited from class com.nhncorp.neptune.parallel.hadoop.AbstractTabletInputFormat

AbstractTabletInputFormat.TabletColumnRecordReader, AbstractTabletInputFormat.TabletRowRecordReader

Field Summary

Fields inherited from class com.nhncorp.neptune.parallel.hadoop.AbstractTabletInputFormat

INPUT_COLUMN_LIST, INPUT_TABLE, OUTPUT_TABLE

Constructor Summary

DefaultTabletInputFormat()

Method Summary

RowFilter	getRowFilter(org.apache.hadoop.mapred.JobConf jobConf) Map에서 처리할 데이터의 Filter 조건을 지정한다.
java.lang.String	getTableName(org.apache.hadoop.mapred.JobConf jobConf) 입력 테이블명을 반환한다.
boolean	isRowScan(org.apache.hadoop.mapred.JobConf jobConf) Scan 모드가 Row단위인지 Cell 단위인지 지정한다.

Methods inherited from class com.nhncorp.neptune.parallel.hadoop.AbstractTabletInputFormat

configure, getRecordReader, getSplits, validateInput

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultTabletInputFormat

public DefaultTabletInputFormat()
                         throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getRowFilter

public RowFilter getRowFilter(org.apache.hadoop.mapred.JobConf jobConf)

Description copied from class: AbstractTabletInputFormat

Map에서 처리할 데이터의 Filter 조건을 지정한다.

Specified by:

getRowFilter in class AbstractTabletInputFormat

Returns:

getTableName

public java.lang.String getTableName(org.apache.hadoop.mapred.JobConf jobConf)

Description copied from class: AbstractTabletInputFormat

입력 테이블명을 반환한다.

Specified by:

getTableName in class AbstractTabletInputFormat

Returns:

isRowScan

public boolean isRowScan(org.apache.hadoop.mapred.JobConf jobConf)

Description copied from class: AbstractTabletInputFormat

Scan 모드가 Row단위인지 Cell 단위인지 지정한다. true를 반환하는 경우 map()에는 Row가 전달되고 false인 경우에는 ScanCell이 전달된다.

Specified by:

isRowScan in class AbstractTabletInputFormat

Returns: