Package org.apache.storm.container.oci

Class HdfsOciResourcesLocalizer

java.lang.Object

org.apache.storm.container.oci.HdfsOciResourcesLocalizer

All Implemented Interfaces:

OciResourcesLocalizerInterface

public class HdfsOciResourcesLocalizer
extends Object
implements OciResourcesLocalizerInterface

Constructor Summary

Constructors

Constructor	Description
HdfsOciResourcesLocalizer()

Method Summary

Modifier and Type	Method	Description
void	init(Map<String,Object> conf)	Initialization.
String	localize(OciResource ociResource)	Download the resources from HDFS to local dir.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.storm.container.oci.OciResourcesLocalizerInterface

localize

Constructor Detail

HdfsOciResourcesLocalizer

public HdfsOciResourcesLocalizer()

Method Detail

init

public void init(Map<String,Object> conf)
          throws IOException

Initialization.

Specified by:

init in interface OciResourcesLocalizerInterface

Parameters:

conf - the storm conf.

Throws:

IOException - on I/O exception

localize

public String localize(OciResource ociResource)
                throws IOException

Download the resources from HDFS to local dir.

Specified by:

localize in interface OciResourcesLocalizerInterface

Parameters:

ociResource - The oci resource to download

Returns:

the destination of the oci resource

Throws:

IOException - on I/O exception