Skip to content

Commit

Permalink
Improved javadoc
Browse files Browse the repository at this point in the history
  • Loading branch information
Daniel Warneke committed Nov 18, 2011
1 parent 9167028 commit a734ce6
Showing 1 changed file with 27 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,14 +22,40 @@
import eu.stratosphere.nephele.plugins.PluginLookupService;
import eu.stratosphere.nephele.plugins.TaskManagerPlugin;

public class StreamingPluginLoader extends AbstractPluginLoader {
/**
* This class implements the loader functionality for the Nephele streaming plugin.
* <p>
* This class is thread-safe.
*
* @author warneke
*/
public final class StreamingPluginLoader extends AbstractPluginLoader {

/**
* The job manager component of this plugin.
*/
private StreamingJobManagerPlugin jobManagerPlugin = null;

/**
* The task manager component of this plugin.
*/
private StreamingTaskManagerPlugin taskManagerPlugin = null;

/**
* The ID of this plugin.
*/
private final PluginID pluginID;

/**
* Constructs a loader for the Nephele streaming plugin.
*
* @param pluginName
* the name of the plugin as specified in the plugin configuration file
* @param pluginConfiguration
* the configuration of this plugin
* @param pluginLookupService
* the lookup service to locate the remote components of this plugin
*/
public StreamingPluginLoader(final String pluginName, final Configuration pluginConfiguration,
final PluginLookupService pluginLookupService) {
super(pluginName, pluginConfiguration, pluginLookupService);
Expand Down Expand Up @@ -73,5 +99,4 @@ public PluginID getPluginID() {

return this.pluginID;
}

}

0 comments on commit a734ce6

Please sign in to comment.