org.springframework.cloud.task.jdbchdfs.common

Class HdfsTextItemWriterFactory

java.lang.Object

org.springframework.cloud.task.jdbchdfs.common.HdfsTextItemWriterFactory

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<HdfsTextItemWriter>, org.springframework.beans.factory.InitializingBean

public class HdfsTextItemWriterFactory
extends Object
implements org.springframework.beans.factory.FactoryBean<HdfsTextItemWriter>, org.springframework.beans.factory.InitializingBean

Factory for configuring a HdfsTextItemWriter. This factory will establish the strategies required for the writer. Specifically, the name and rollover strategy as well as establish the temporary extension.

Author:

Glenn Renfro

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAMENODE_PRINCIPAL
static String	PROPERTIES_LOCATION
static String	REGISTER_URL_HANDLER
static String	RM_MANAGER_PRINCIPAL
static String	SECURITY_METHOD
static String	USER_KEYTAB
static String	USER_PRINCIPAL

Constructor Summary

Constructors

Constructor and Description
HdfsTextItemWriterFactory(org.apache.hadoop.conf.Configuration configuration, JdbcHdfsTaskProperties props, String partitionSuffix)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
HdfsTextItemWriter	getObject()
Class<?>	getObjectType()
boolean	isSingleton()

Methods inherited from class java.lang.Object

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

Field Detail

RM_MANAGER_PRINCIPAL

public static final String RM_MANAGER_PRINCIPAL

See Also:

Constant Field Values

NAMENODE_PRINCIPAL

public static final String NAMENODE_PRINCIPAL

See Also:

Constant Field Values

USER_PRINCIPAL

public static final String USER_PRINCIPAL

See Also:

Constant Field Values

USER_KEYTAB

public static final String USER_KEYTAB

See Also:

Constant Field Values

SECURITY_METHOD

public static final String SECURITY_METHOD

See Also:

Constant Field Values

PROPERTIES_LOCATION

public static final String PROPERTIES_LOCATION

See Also:

Constant Field Values

REGISTER_URL_HANDLER

public static final String REGISTER_URL_HANDLER

See Also:

Constant Field Values

Constructor Detail

HdfsTextItemWriterFactory

public HdfsTextItemWriterFactory(org.apache.hadoop.conf.Configuration configuration,
                                 JdbcHdfsTaskProperties props,
                                 String partitionSuffix)
                          throws Exception

Throws:

Exception

Method Detail

getObject

public HdfsTextItemWriter getObject()
                             throws Exception

Specified by:

getObject in interface org.springframework.beans.factory.FactoryBean<HdfsTextItemWriter>

Throws:

Exception

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface org.springframework.beans.factory.FactoryBean<HdfsTextItemWriter>

isSingleton

public boolean isSingleton()

Specified by:

isSingleton in interface org.springframework.beans.factory.FactoryBean<HdfsTextItemWriter>

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception