org.apache.storm.localizer

Class AsyncLocalizer

java.lang.Object

org.apache.storm.localizer.AsyncLocalizer

All Implemented Interfaces:

Shutdownable, ILocalizer

public class AsyncLocalizer
extends Object
implements ILocalizer, Shutdownable

This is a wrapper around the Localizer class that provides the desired async interface to Slot.

Constructor Summary

Constructors

Constructor and Description
AsyncLocalizer(Map<String,Object> conf, Localizer localizer)

Method Summary

Modifier and Type	Method and Description
void	cleanupUnusedTopologies() Clean up any topologies that are not in use right now.
void	recoverRunningTopology(LocalAssignment assignment, int port) Recover a running topology by incrementing references for what it has already downloaded.
void	releaseSlotFor(LocalAssignment assignment, int port) dec reference count on all blobs associated with this topology.
Future<Void>	requestDownloadBaseTopologyBlobs(LocalAssignment assignment, int port) Download storm.jar, storm.conf, and storm.ser for this topology if not done so already, and inc a reference count on them.
Future<Void>	requestDownloadTopologyBlobs(LocalAssignment assignment, int port) Download the blobs for this topology (reading in list in from the config) and inc reference count for these blobs.
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncLocalizer

public AsyncLocalizer(Map<String,Object> conf,
                      Localizer localizer)

Method Detail

requestDownloadBaseTopologyBlobs

public Future<Void> requestDownloadBaseTopologyBlobs(LocalAssignment assignment,
                                                     int port)
                                              throws IOException

Description copied from interface: ILocalizer

Download storm.jar, storm.conf, and storm.ser for this topology if not done so already, and inc a reference count on them.

Specified by:

requestDownloadBaseTopologyBlobs in interface ILocalizer

Parameters:

assignment - the assignment the resources are for

port - the port the topology is running on

Returns:

a future to let you know when they are done.

Throws:

IOException - on error

recoverRunningTopology

public void recoverRunningTopology(LocalAssignment assignment,
                                   int port)

Description copied from interface: ILocalizer

Recover a running topology by incrementing references for what it has already downloaded.

Specified by:

recoverRunningTopology in interface ILocalizer

port - the port the topology is running in.

requestDownloadTopologyBlobs

public Future<Void> requestDownloadTopologyBlobs(LocalAssignment assignment,
                                                 int port)

Description copied from interface: ILocalizer

Download the blobs for this topology (reading in list in from the config) and inc reference count for these blobs. PRECONDITION: requestDownloadBaseTopologyBlobs has completed downloading.

Specified by:

requestDownloadTopologyBlobs in interface ILocalizer

Parameters:

assignment - the assignment the resources are for

port - the port the topology is running on

Returns:

a future to let you know when they are done.

releaseSlotFor

public void releaseSlotFor(LocalAssignment assignment,
                           int port)
                    throws IOException

Description copied from interface: ILocalizer

dec reference count on all blobs associated with this topology.

Specified by:

releaseSlotFor in interface ILocalizer

Parameters:

assignment - the assignment the resources are for

port - the port the topology is running on

Throws:

IOException - on any error

cleanupUnusedTopologies

public void cleanupUnusedTopologies()
                             throws IOException

Description copied from interface: ILocalizer

Clean up any topologies that are not in use right now.

Specified by:

cleanupUnusedTopologies in interface ILocalizer

Throws:

IOException - on any error.

shutdown

public void shutdown()

Specified by:

shutdown in interface Shutdownable