本文整理汇总了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;未经允许,请勿转载。 |
请发表评论