co.cask.hydrator.common.batch.sink

Class SinkOutputFormatProvider

java.lang.Object

co.cask.hydrator.common.batch.sink.SinkOutputFormatProvider

All Implemented Interfaces:

co.cask.cdap.api.data.batch.OutputFormatProvider

public final class SinkOutputFormatProvider
extends Object
implements co.cask.cdap.api.data.batch.OutputFormatProvider

An implementation of OutputFormatProvider based on Configuration and output format class.

Constructor Summary

Constructors

Constructor and Description
SinkOutputFormatProvider(Class<? extends org.apache.hadoop.mapreduce.OutputFormat> outputFormatClass, org.apache.hadoop.conf.Configuration hConf)
SinkOutputFormatProvider(String outputFormatClassName, org.apache.hadoop.conf.Configuration hConf)
SinkOutputFormatProvider(String outputFormatClassName, Map<String,String> configuration)

Method Summary

Methods

Modifier and Type	Method and Description
String	getOutputFormatClassName()
Map<String,String>	getOutputFormatConfiguration()

Methods inherited from class java.lang.Object

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

Constructor Detail

SinkOutputFormatProvider

public SinkOutputFormatProvider(Class<? extends org.apache.hadoop.mapreduce.OutputFormat> outputFormatClass,
                        org.apache.hadoop.conf.Configuration hConf)

SinkOutputFormatProvider

public SinkOutputFormatProvider(String outputFormatClassName,
                        org.apache.hadoop.conf.Configuration hConf)

SinkOutputFormatProvider

public SinkOutputFormatProvider(String outputFormatClassName,
                        Map<String,String> configuration)

Method Detail

getOutputFormatClassName

public String getOutputFormatClassName()

Specified by:

getOutputFormatClassName in interface co.cask.cdap.api.data.batch.OutputFormatProvider

getOutputFormatConfiguration

public Map<String,String> getOutputFormatConfiguration()

Specified by:

getOutputFormatConfiguration in interface co.cask.cdap.api.data.batch.OutputFormatProvider