co.cask.hydrator.common

Class SourceInputFormatProvider

java.lang.Object

co.cask.hydrator.common.SourceInputFormatProvider

All Implemented Interfaces:

co.cask.cdap.api.data.batch.InputFormatProvider

public final class SourceInputFormatProvider
extends Object
implements co.cask.cdap.api.data.batch.InputFormatProvider

An implementation of InputFormatProvider based on Configuration and input format class.

Constructor Summary

Constructors

Constructor and Description
SourceInputFormatProvider(Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass, org.apache.hadoop.conf.Configuration hConf)
SourceInputFormatProvider(String inputFormatClassName, org.apache.hadoop.conf.Configuration hConf)

Method Summary

Methods

Modifier and Type	Method and Description
String	getInputFormatClassName()
Map<String,String>	getInputFormatConfiguration()

Methods inherited from class java.lang.Object

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

Constructor Detail

SourceInputFormatProvider

public SourceInputFormatProvider(Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass,
                         org.apache.hadoop.conf.Configuration hConf)

SourceInputFormatProvider

public SourceInputFormatProvider(String inputFormatClassName,
                         org.apache.hadoop.conf.Configuration hConf)

Method Detail

getInputFormatClassName

public String getInputFormatClassName()

Specified by:

getInputFormatClassName in interface co.cask.cdap.api.data.batch.InputFormatProvider

getInputFormatConfiguration

public Map<String,String> getInputFormatConfiguration()

Specified by:

getInputFormatConfiguration in interface co.cask.cdap.api.data.batch.InputFormatProvider