public class ConfigurationFactoryBean
extends java.lang.Object
implements org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.FactoryBean<org.apache.hadoop.conf.Configuration>
Configuration
instances.Constructor and Description |
---|
ConfigurationFactoryBean() |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
protected org.apache.hadoop.conf.Configuration |
createConfiguration(org.apache.hadoop.conf.Configuration existing)
Creates a configuration instance potentially using the existing one (passed as an argument - which can be null).
|
org.apache.hadoop.conf.Configuration |
getObject() |
java.lang.Class<?> |
getObjectType() |
boolean |
isSingleton() |
protected void |
postProcessConfiguration(org.apache.hadoop.conf.Configuration configuration) |
void |
setBeanClassLoader(java.lang.ClassLoader classLoader) |
void |
setConfiguration(org.apache.hadoop.conf.Configuration configuration)
Sets the parent configuration.
|
void |
setFileSystemUri(java.lang.String fsUri)
Sets the File System ('fs.default.name') and ('fs.defaultFS') URI
for HadoopV1 and HadoopV2 respectively.
|
void |
setInitialize(boolean initialize)
Indicates whether the configuration object should be initialized (true) or not.
|
void |
setJobTrackerUri(java.lang.String jtUri)
Sets the Job Tracker ('mapred.jobtracker') URI for HadoopV1.
|
void |
setLoadDefaults(boolean loadDefaults)
Indicates whether to load the defaults (the default) or not for this configuration.
|
void |
setProperties(java.util.Properties properties)
Sets the configuration properties.
|
void |
setRegisterUrlHandler(boolean register)
Indicates whether the configuration should register an URL handler (for allowing urls
to understand HDFS prefixes, such as hdfs) or not.
|
void |
setResources(java.util.Set<org.springframework.core.io.Resource> resources)
Sets the configuration resources.
|
void |
setRmManagerUri(java.lang.String rmUri)
Sets the Yarn resource manager ('yarn.resourcemanager.address') URI for HadoopV2.
|
public void afterPropertiesSet() throws java.lang.Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
java.lang.Exception
public org.apache.hadoop.conf.Configuration getObject()
getObject
in interface org.springframework.beans.factory.FactoryBean<org.apache.hadoop.conf.Configuration>
public java.lang.Class<?> getObjectType()
getObjectType
in interface org.springframework.beans.factory.FactoryBean<org.apache.hadoop.conf.Configuration>
public boolean isSingleton()
isSingleton
in interface org.springframework.beans.factory.FactoryBean<org.apache.hadoop.conf.Configuration>
public void setBeanClassLoader(java.lang.ClassLoader classLoader)
setBeanClassLoader
in interface org.springframework.beans.factory.BeanClassLoaderAware
protected org.apache.hadoop.conf.Configuration createConfiguration(org.apache.hadoop.conf.Configuration existing)
existing
- existing configurationprotected void postProcessConfiguration(org.apache.hadoop.conf.Configuration configuration)
public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)
configuration
- The configuration to set.public void setLoadDefaults(boolean loadDefaults)
loadDefaults
- The loadDefaults to set.public void setResources(java.util.Set<org.springframework.core.io.Resource> resources)
resources
- The resources to set.public void setProperties(java.util.Properties properties)
properties
- The properties to set.public void setInitialize(boolean initialize)
initialize
- whether to initialize or not.public void setRegisterUrlHandler(boolean register)
register
- whether to register an URL handler or notpublic void setFileSystemUri(java.lang.String fsUri)
fsUri
- the default file system uripublic void setJobTrackerUri(java.lang.String jtUri)
jtUri
- the job tracker uripublic void setRmManagerUri(java.lang.String rmUri)
rmUri
- the resource manager uri