public class DefaultLocalResourcesHdfsConfigurer extends AnnotationConfigurerAdapter<ResourceLocalizer,YarnResourceLocalizerConfigurer,YarnResourceLocalizerBuilder> implements LocalResourcesHdfsConfigurer
Constructor and Description |
---|
DefaultLocalResourcesHdfsConfigurer()
Instantiates a new default local resources hdfs configurer.
|
DefaultLocalResourcesHdfsConfigurer(java.lang.String id)
Instantiates a new default local resources hdfs configurer.
|
Modifier and Type | Method and Description |
---|---|
void |
configure(YarnResourceLocalizerBuilder builder)
Configure the
AnnotationBuilder by setting the necessary properties
on the AnnotationBuilder . |
LocalResourcesHdfsConfigurer |
hdfs(java.lang.String path) |
LocalResourcesHdfsConfigurer |
hdfs(java.lang.String path,
org.apache.hadoop.yarn.api.records.LocalResourceType type) |
LocalResourcesHdfsConfigurer |
hdfs(java.lang.String path,
org.apache.hadoop.yarn.api.records.LocalResourceType type,
boolean staging) |
LocalResourcesHdfsConfigurer |
hdfs(java.lang.String dir,
java.lang.String file) |
LocalResourcesHdfsConfigurer |
hdfs(java.lang.String dir,
java.lang.String file,
org.apache.hadoop.yarn.api.records.LocalResourceType type) |
addObjectPostProcessor, and, getBuilder, init, isAssignable, setBuilder
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
and
public DefaultLocalResourcesHdfsConfigurer()
public DefaultLocalResourcesHdfsConfigurer(java.lang.String id)
id
- the identifierpublic void configure(YarnResourceLocalizerBuilder builder) throws java.lang.Exception
AnnotationConfigurer
AnnotationBuilder
by setting the necessary properties
on the AnnotationBuilder
.configure
in interface AnnotationConfigurer<ResourceLocalizer,YarnResourceLocalizerBuilder>
configure
in class AnnotationConfigurerAdapter<ResourceLocalizer,YarnResourceLocalizerConfigurer,YarnResourceLocalizerBuilder>
builder
- the builderjava.lang.Exception
- if error occurredpublic LocalResourcesHdfsConfigurer hdfs(java.lang.String path)
hdfs
in interface LocalResourcesHdfsConfigurer
public LocalResourcesHdfsConfigurer hdfs(java.lang.String dir, java.lang.String file)
hdfs
in interface LocalResourcesHdfsConfigurer
public LocalResourcesHdfsConfigurer hdfs(java.lang.String path, org.apache.hadoop.yarn.api.records.LocalResourceType type)
hdfs
in interface LocalResourcesHdfsConfigurer
public LocalResourcesHdfsConfigurer hdfs(java.lang.String path, org.apache.hadoop.yarn.api.records.LocalResourceType type, boolean staging)
hdfs
in interface LocalResourcesHdfsConfigurer
public LocalResourcesHdfsConfigurer hdfs(java.lang.String dir, java.lang.String file, org.apache.hadoop.yarn.api.records.LocalResourceType type)
hdfs
in interface LocalResourcesHdfsConfigurer