Storm中的数据并行性(Data parallelism in Storm)

 要执行此功能，您必须使用插件加载器。 使用插件加载器加载类。 
 
 这是一个加载器类，用于在/ library / Xyz / Fld1 / Fld2 / Fld3 /目录中加载自定义类 
 
 这是一个代码示例。 
 
<?php
class Xyz_Core
{
  /**
   * File name Core.php inside Xyz directory
   * 
   * Loader for parsers
   * 
   * @var Zend_Loader_PluginLoader
   */
  protected $_pluginLoader;


  /**
   * Gets the plugin loader
   * 
   * @return Zend_Loader_PluginLoader
   */
  public function getPluginLoader()
  {
    if( null === $this->_pluginLoader )
    {
      $this->_pluginLoader = new Zend_Loader_PluginLoader(array(
        'Xyz_Fld1_Fld2_Fld3_' => 'XYZ/fld1/fld2/fld3/'
      ));
    }

    return $this->_pluginLoader;
  }

  /**
   * Get a helper
   * 
   * @param string $name
   */
  public function getHelper($name)
  {
    $name = $this->_normalizeHelperName($name);
    if( !isset($this->_helpers[$name]) )
    {
      $helper = $this->getPluginLoader()->load($name);
      $this->_helpers[$name] = new $helper;
    }

    return $this->_helpers[$name];
  }

  /**
   * Normalize helper name
   * 
   * @param string $name
   * @return string
   */
  protected function _normalizeHelperName($name)
  {
    $name = preg_replace('/[^A-Za-z0-9]/', '', $name);
    //$name = strtolower($name);
    $name = ucfirst($name);
    return $name;
  }
}

$api = new Xyz_Core();
/*
 * To load object of class Example.php
 */
$obj = $api->getHelper('Example');
/*
 * Or To load include the file only of class Example.php
 */
$class = $api->getPluginLoader()->load('Example');
$obj = new $class($param1, $param2, $etc);

To do the functionality you have to use plugin loader. Using plugin loader you load classes.
 
This is a loader class to load custom classes inside your /library/Xyz/Fld1/Fld2/Fld3/ directory
 
Here is a code sample.
 
<?php
class Xyz_Core
{
  /**
   * File name Core.php inside Xyz directory
   * 
   * Loader for parsers
   * 
   * @var Zend_Loader_PluginLoader
   */
  protected $_pluginLoader;


  /**
   * Gets the plugin loader
   * 
   * @return Zend_Loader_PluginLoader
   */
  public function getPluginLoader()
  {
    if( null === $this->_pluginLoader )
    {
      $this->_pluginLoader = new Zend_Loader_PluginLoader(array(
        'Xyz_Fld1_Fld2_Fld3_' => 'XYZ/fld1/fld2/fld3/'
      ));
    }

    return $this->_pluginLoader;
  }

  /**
   * Get a helper
   * 
   * @param string $name
   */
  public function getHelper($name)
  {
    $name = $this->_normalizeHelperName($name);
    if( !isset($this->_helpers[$name]) )
    {
      $helper = $this->getPluginLoader()->load($name);
      $this->_helpers[$name] = new $helper;
    }

    return $this->_helpers[$name];
  }

  /**
   * Normalize helper name
   * 
   * @param string $name
   * @return string
   */
  protected function _normalizeHelperName($name)
  {
    $name = preg_replace('/[^A-Za-z0-9]/', '', $name);
    //$name = strtolower($name);
    $name = ucfirst($name);
    return $name;
  }
}

$api = new Xyz_Core();
/*
 * To load object of class Example.php
 */
$obj = $api->getHelper('Example');
/*
 * Or To load include the file only of class Example.php
 */
$class = $api->getPluginLoader()->load('Example');
$obj = new $class($param1, $param2, $etc);