• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java PartitionerPluginType类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.pentaho.di.core.plugins.PartitionerPluginType的典型用法代码示例。如果您正苦于以下问题:Java PartitionerPluginType类的具体用法?Java PartitionerPluginType怎么用?Java PartitionerPluginType使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



PartitionerPluginType类属于org.pentaho.di.core.plugins包,在下文中一共展示了PartitionerPluginType类的13个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: getMethodType

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
public static final int getMethodType(String description)
{
    for (int i=0;i<methodDescriptions.length;i++)
    {
        if (methodDescriptions[i].equalsIgnoreCase(description)){
        	return i;
        }
    }
    
    for (int i=0;i<methodCodes.length;i++)
    {
        if (methodCodes[i].equalsIgnoreCase(description)) return i;
    }
    
    PluginInterface plugin = PluginRegistry.getInstance().findPluginWithId(PartitionerPluginType.class, description );
    if(  plugin != null ) {
    	return PARTITIONING_METHOD_SPECIAL;
    }
    return PARTITIONING_METHOD_NONE;
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:21,代码来源:StepPartitioningMeta.java


示例2: createPartitioner

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
public void createPartitioner( String method ) throws KettlePluginException {
	methodType = getMethodType(method);
    switch ( methodType ) {
    case PARTITIONING_METHOD_SPECIAL: {
    	PluginRegistry registry = PluginRegistry.getInstance();
    	PluginInterface plugin = registry.findPluginWithId(PartitionerPluginType.class, method);
    	partitioner = (Partitioner) registry.loadClass(plugin);
    	partitioner.setId(plugin.getIds()[0]);
    	break;
    }
    case PARTITIONING_METHOD_NONE:
    default: partitioner = null;
    }
    if( partitioner != null ) 
    {
    	partitioner.setMeta(this);
    }
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:19,代码来源:StepPartitioningMeta.java


示例3: getMethodType

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
public static final int getMethodType( String description ) {
  for ( int i = 0; i < methodDescriptions.length; i++ ) {
    if ( methodDescriptions[i].equalsIgnoreCase( description ) ) {
      return i;
    }
  }

  for ( int i = 0; i < methodCodes.length; i++ ) {
    if ( methodCodes[i].equalsIgnoreCase( description ) ) {
      return i;
    }
  }

  PluginInterface plugin =
    PluginRegistry.getInstance().findPluginWithId( PartitionerPluginType.class, description );
  if ( plugin != null ) {
    return PARTITIONING_METHOD_SPECIAL;
  }
  return PARTITIONING_METHOD_NONE;
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:21,代码来源:StepPartitioningMeta.java


示例4: createPartitioner

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
public void createPartitioner( String method ) throws KettlePluginException {
  methodType = getMethodType( method );
  switch ( methodType ) {
    case PARTITIONING_METHOD_SPECIAL: {
      PluginRegistry registry = PluginRegistry.getInstance();
      PluginInterface plugin = registry.findPluginWithId( PartitionerPluginType.class, method );
      partitioner = (Partitioner) registry.loadClass( plugin );
      partitioner.setId( plugin.getIds()[0] );
      break;
    }
    case PARTITIONING_METHOD_NONE:
    default:
      partitioner = null;
  }
  if ( partitioner != null ) {
    partitioner.setMeta( this );
  }
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:19,代码来源:StepPartitioningMeta.java


示例5: init

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
/**
 * Initializes the Kettle environment. This method performs the following operations:
 * <p/>
 * - Creates a Kettle "home" directory if it does not already exist - Reads in the kettle.properties file -
 * Initializes the logging back-end - Sets the console log level to debug - If specified by parameter, configures
 * Simple JNDI - Registers the native types and the plugins for the various plugin types - Reads the list of variables
 * - Initializes the Lifecycle listeners
 *
 * @param simpleJndi true to configure Simple JNDI, false otherwise
 * @throws KettleException Any errors that occur during initialization will throw a KettleException.
 */
public static void init( boolean simpleJndi ) throws KettleException {
  init( Arrays.asList(
    RowDistributionPluginType.getInstance(),
    StepPluginType.getInstance(),
    StepDialogFragmentType.getInstance(),
    PartitionerPluginType.getInstance(),
    JobEntryPluginType.getInstance(),
    LogTablePluginType.getInstance(),
    RepositoryPluginType.getInstance(),
    LifecyclePluginType.getInstance(),
    KettleLifecyclePluginType.getInstance(),
    ImportRulePluginType.getInstance(),
    CartePluginType.getInstance(),
    CompressionPluginType.getInstance(),
    AuthenticationProviderPluginType.getInstance(),
    AuthenticationConsumerPluginType.getInstance(),
    EnginePluginType.getInstance()
  ), simpleJndi );
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:31,代码来源:KettleEnvironment.java


示例6: init

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
/**
	 * 初始化Ketle环境。此方法执行以下 操作:
	 * 
	 * 创建一个Kettle "home" 的目录,如果它已经不存在 - 读取 在kettle.properties文件 - 初始化记录后端 - 设置
	 * 控制台日志级别调试 - 如果指定的参数,配置 简单的JNDI - 寄存器的各种原生类型和插件 插件类型 - 读取变量列表 - 初始化生命周期
	 * 启动监听程序等
	 * 
	 * @param simpleJndi
	 *            , 真正简单的JNDI配置,否则返回false
	 * @throws KettleException
	 *             在初始化过程中发生的任何错误都将抛出 KettleException。
	 */
	public static void init(boolean simpleJndi) throws KettleException {
		if (initialized == null) {
			// 创建一个Kettle "home" 的目录
			// createKettleHome();
			// 初始化 kettle.properties 初始化其他属性等
			environmentInit();
			// 初始化日志
//			CentralLogStore.init();
//			// 设置控制台日志级用来调试
//			LogWriter.setConsoleAppenderDebug();
			// 配置简单的JNDI 仅供我们在单机模式运行
			if (simpleJndi) {
				JndiUtil.initJNDI();
			}
			// 注册原生类型和各个所需的插件
			PluginRegistry.addPluginType(StepPluginType.getInstance());
			PluginRegistry.addPluginType(PartitionerPluginType.getInstance());
			PluginRegistry.addPluginType(JobEntryPluginType.getInstance());
			PluginRegistry.addPluginType(RepositoryPluginType.getInstance());
			PluginRegistry.addPluginType(DatabasePluginType.getInstance());
			PluginRegistry.addPluginType(LifecyclePluginType.getInstance());
			PluginRegistry.addPluginType(KettleLifecyclePluginType
					.getInstance());
			PluginRegistry.addPluginType(ImportRulePluginType.getInstance());
			PluginRegistry.init();
			// 初始化读取的变量列表。
			KettleVariablesList.init();
			// 初始化生命周期监听器
			initLifecycleListeners();
			initialized = true;
		}
	}
 
开发者ID:jiangzongyao,项目名称:kettle_support_kettle8.0,代码行数:45,代码来源:KettleEnvironment.java


示例7: init

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
/**
 * 初始化Ketle环境。此方法执行以下 操作:
 * 
 * 创建一个Kettle "home" 的目录,如果它已经不存在 - 读取 在kettle.properties文件 - 初始化记录后端 - 设置
 * 控制台日志级别调试 - 如果指定的参数,配置 简单的JNDI - 寄存器的各种原生类型和插件 插件类型 - 读取变量列表 - 初始化生命周期
 * 启动监听程序等
 * 
 * @param simpleJndi
 *            , 真正简单的JNDI配置,否则返回false
 * @throws KettleException
 *             在初始化过程中发生的任何错误都将抛出 KettleException。
 */
public static void init(boolean simpleJndi) throws KettleException {
	if (initialized == null) {
		// 创建一个Kettle "home" 的目录
		// createKettleHome();
		// 初始化 kettle.properties 初始化其他属性等
		environmentInit();
		// 初始化日志
		CentralLogStore.init();
		// 设置控制台日志级用来调试
		LogWriter.setConsoleAppenderDebug();
		// 配置简单的JNDI 仅供我们在单机模式运行
		if (simpleJndi) {
			JndiUtil.initJNDI();
		}
		// 注册原生类型和各个所需的插件
		PluginRegistry.addPluginType(StepPluginType.getInstance());
		PluginRegistry.addPluginType(PartitionerPluginType.getInstance());
		PluginRegistry.addPluginType(JobEntryPluginType.getInstance());
		PluginRegistry.addPluginType(RepositoryPluginType.getInstance());
		PluginRegistry.addPluginType(DatabasePluginType.getInstance());
		PluginRegistry.addPluginType(LifecyclePluginType.getInstance());
		PluginRegistry.addPluginType(KettleLifecyclePluginType
				.getInstance());
		PluginRegistry.addPluginType(ImportRulePluginType.getInstance());
		PluginRegistry.init();
		// 初始化读取的变量列表。
		KettleVariablesList.init();
		// 初始化生命周期监听器
		initLifecycleListeners();
		initialized = true;
	}
}
 
开发者ID:839536,项目名称:kettle,代码行数:45,代码来源:KettleEnvironment.java


示例8: getMethod

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
public static final String getMethod(String name)
{
	if (Const.isEmpty(name)) return methodCodes[PARTITIONING_METHOD_NONE];
	
    for (int i=0;i<methodDescriptions.length;i++)
    {
        if (methodDescriptions[i].equalsIgnoreCase(name)){
        	return methodCodes[i];
        }
    }
    
    for (int i=0;i<methodCodes.length;i++)
    {
        if (methodCodes[i].equalsIgnoreCase(name)) return methodCodes[i];
    }
    
    PluginRegistry registry = PluginRegistry.getInstance();
    PluginInterface plugin = registry.findPluginWithName(PartitionerPluginType.class, name);
    if( plugin != null ) {
    	return name;
    }
    plugin = registry.findPluginWithId(PartitionerPluginType.class, name);
    if( plugin != null ) {
    	return name;
    }

    
    return methodCodes[PARTITIONING_METHOD_NONE];
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:30,代码来源:StepPartitioningMeta.java


示例9: getMethod

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
public static final String getMethod( String name ) {
  if ( Utils.isEmpty( name ) ) {
    return methodCodes[PARTITIONING_METHOD_NONE];
  }

  for ( int i = 0; i < methodDescriptions.length; i++ ) {
    if ( methodDescriptions[i].equalsIgnoreCase( name ) ) {
      return methodCodes[i];
    }
  }

  for ( int i = 0; i < methodCodes.length; i++ ) {
    if ( methodCodes[i].equalsIgnoreCase( name ) ) {
      return methodCodes[i];
    }
  }

  PluginRegistry registry = PluginRegistry.getInstance();
  PluginInterface plugin = registry.findPluginWithName( PartitionerPluginType.class, name );
  if ( plugin != null ) {
    return name;
  }
  plugin = registry.findPluginWithId( PartitionerPluginType.class, name );
  if ( plugin != null ) {
    return name;
  }

  return methodCodes[PARTITIONING_METHOD_NONE];
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:30,代码来源:StepPartitioningMeta.java


示例10: setShellImage

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
private void setShellImage( Shell shell ) {
  PluginInterface plugin = PluginRegistry.getInstance().getPlugin( PartitionerPluginType.class, partitioner.getId() );
  if ( !Utils.isEmpty( plugin.getDocumentationUrl() ) ) {
    createHelpButton( shell, stepMeta, plugin );
  }

  shell.setImage( GUIResource.getInstance().getImageSpoon() );
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:9,代码来源:ModPartitionerDialog.java


示例11: init

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
public static void init(boolean simpleJndi) throws KettleException {
	if (initialized==null) {
		
		// Create a home for Kettle if it doesn't exist yet.
		//
		createKettleHome();
		
		// Read the kettle.properties file before anything else
		//
		EnvUtil.environmentInit();
		
		// Initialize the logging back-end.
		//
		CentralLogStore.init();
		
		// Set the console log level to debug
		//
		LogWriter.setConsoleAppenderDebug();
		
		// Configure Simple JNDI when we run in stand-alone mode (spoon, pan, kitchen, carte, ... NOT on the platform
		//
		if (simpleJndi) {
		  JndiUtil.initJNDI();
		}
		
		// Register the native types and the plugins for the various plugin types...
		//
		PluginRegistry.addPluginType(StepPluginType.getInstance());
		PluginRegistry.addPluginType(PartitionerPluginType.getInstance());
		PluginRegistry.addPluginType(JobEntryPluginType.getInstance());
		PluginRegistry.addPluginType(RepositoryPluginType.getInstance());
		PluginRegistry.addPluginType(DatabasePluginType.getInstance());
		PluginRegistry.addPluginType(LifecyclePluginType.getInstance());
     PluginRegistry.addPluginType(ImportRulePluginType.getInstance());
		PluginRegistry.init();
		
		// Also read the list of variables.
		//
		KettleVariablesList.init();
					
		initialized = true;
	}
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:44,代码来源:KettleEnvironment.java


示例12: init

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
/**
 * Initializes the Kettle environment. This method performs the following operations:
 * 
 *  - Creates a Kettle "home" directory if it does not already exist
 *  - Reads in the kettle.properties file
 *  - Initializes the logging back-end
 *  - Sets the console log level to debug
 *  - If specified by parameter, configures Simple JNDI
 *  - Registers the native types and the plugins for the various plugin types
 *  - Reads the list of variables
 *  - Initializes the Lifecycle listeners   
 *
 * @param simpleJndi true to configure Simple JNDI, false otherwise
 * @throws KettleException Any errors that occur during initialization will throw a KettleException.
 */
public static void init(boolean simpleJndi) throws KettleException {
	if (initialized==null) {
		
		// Create a home for Kettle if it doesn't exist yet.
		//
		createKettleHome();
		
		// Read the kettle.properties file before anything else
		//
		EnvUtil.environmentInit();
		
		// Initialize the logging back-end.
		//
		CentralLogStore.init();
		
		// Set the console log level to debug
		//
		LogWriter.setConsoleAppenderDebug();
		
		// Configure Simple JNDI when we run in stand-alone mode (spoon, pan, kitchen, carte, ... NOT on the platform
		//
		if (simpleJndi) {
		  JndiUtil.initJNDI();
		}
		
		// Register the native types and the plugins for the various plugin types...
		//
		PluginRegistry.addPluginType(StepPluginType.getInstance());
		PluginRegistry.addPluginType(PartitionerPluginType.getInstance());
		PluginRegistry.addPluginType(JobEntryPluginType.getInstance());
		PluginRegistry.addPluginType(RepositoryPluginType.getInstance());
		PluginRegistry.addPluginType(DatabasePluginType.getInstance());
		PluginRegistry.addPluginType(LifecyclePluginType.getInstance());
		PluginRegistry.addPluginType(KettleLifecyclePluginType.getInstance());
		PluginRegistry.addPluginType(ImportRulePluginType.getInstance());
		PluginRegistry.init();
		
		// Also read the list of variables.
		//
		KettleVariablesList.init();

		// Initialize the Lifecycle Listeners
		//
		initLifecycleListeners();
					
		initialized = true;
	}
}
 
开发者ID:bsspirit,项目名称:kettle-4.4.0-stable,代码行数:64,代码来源:KettleEnvironment.java


示例13: init

import org.pentaho.di.core.plugins.PartitionerPluginType; //导入依赖的package包/类
/**
 * Initializes the Kettle environment. This method performs the following operations:
 * 
 *  - Creates a Kettle "home" directory if it does not already exist
 *  - Reads in the kettle.properties file
 *  - Initializes the logging back-end
 *  - Sets the console log level to debug
 *  - If specified by parameter, configures Simple JNDI
 *  - Registers the native types and the plugins for the various plugin types
 *  - Reads the list of variables
 *  - Initializes the Lifecycle listeners   
 *
 * @param simpleJndi true to configure Simple JNDI, false otherwise
 * @throws KettleException Any errors that occur during initialization will throw a KettleException.
 */
public static void init(boolean simpleJndi) throws KettleException {
	if (initialized==null) {

		// This creates .kettle and kettle.properties...
		//
		if (!KettleClientEnvironment.isInitialized()) {
			KettleClientEnvironment.init();
		}
		
		// Initialize the logging back-end.
		//
		CentralLogStore.init();
		
		// Set the console log level to debug
		//
		LogWriter.setConsoleAppenderDebug();
		
		// Configure Simple JNDI when we run in stand-alone mode (spoon, pan, kitchen, carte, ... NOT on the platform
		//
		if (simpleJndi) {
		  JndiUtil.initJNDI();
		}
		
		// Register the native types and the plugins for the various plugin types...
		//
		PluginRegistry.addPluginType(StepPluginType.getInstance());
		PluginRegistry.addPluginType(PartitionerPluginType.getInstance());
		PluginRegistry.addPluginType(JobEntryPluginType.getInstance());
		PluginRegistry.addPluginType(RepositoryPluginType.getInstance());
		PluginRegistry.addPluginType(DatabasePluginType.getInstance());
		PluginRegistry.addPluginType(LifecyclePluginType.getInstance());
		PluginRegistry.addPluginType(KettleLifecyclePluginType.getInstance());
     PluginRegistry.addPluginType(ImportRulePluginType.getInstance());
     PluginRegistry.addPluginType(CartePluginType.getInstance());
		PluginRegistry.init();
		
		// Also read the list of variables.
		//
		KettleVariablesList.init();

		// Initialize the Lifecycle Listeners
		//
		initLifecycleListeners();
					
		initialized = true;
	}
}
 
开发者ID:jjeb,项目名称:kettle-trunk,代码行数:63,代码来源:KettleEnvironment.java



注:本文中的org.pentaho.di.core.plugins.PartitionerPluginType类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java Video类代码示例发布时间:2022-05-23
下一篇:
Java RootViewUtil类代码示例发布时间:2022-05-23
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap