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

Java JobEntryPluginType类代码示例

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

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



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

示例1: isBigDataPluginInstalled

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public boolean isBigDataPluginInstalled() throws KettleException
{
  if( PluginRegistry.getInstance().findPluginWithId( JobEntryPluginType.class, "HadoopTransJobExecutorPlugin" ) != null )
  {
    try {

      PluginRegistry.getInstance().loadClass(
        PluginRegistry.getInstance().findPluginWithId( JobEntryPluginType.class, "HadoopTransJobExecutorPlugin" ) );
    } catch (KettlePluginException ex)
    {
      throw new KettleException( ex.getMessage(), ex );
    }
    return true;
  }
  return false;
}
 
开发者ID:inquidia,项目名称:ParquetPlugin,代码行数:17,代码来源:ParquetOutputMeta.java


示例2: doGet

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
@Override
public void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
    resp.setContentType("application/json");
    final PluginRegistry registry = PluginRegistry.getInstance();
    final List<PluginInterface> basesteps = registry.getPlugins(JobEntryPluginType.class);
    final List<String> basecat = registry.getCategories(JobEntryPluginType.class);

    List<Map<String, Object>> categoryList = new ArrayList<Map<String, Object>>();
    Map<String, Map<String, Object>> categoryMap = new HashMap<String, Map<String, Object>>();
    for (String category : basecat) {
        getCategoryMap(category, categoryList, categoryMap);
    }
    addEntry(categoryList, categoryMap, "General", JobMeta.STRING_SPECIAL_START, "Start");
    addEntry(categoryList, categoryMap, "General", JobMeta.STRING_SPECIAL_DUMMY, "Dummy");
    for (PluginInterface pluginInterface : basesteps) {
        // Because these are called out differently in kettle
        if ("SPECIAL".equals(pluginInterface.getIds()[0])) {
            continue;
        }
        addEntry(categoryList, categoryMap, pluginInterface.getCategory(), pluginInterface.getIds()[0], pluginInterface.getName()) ;
    }

    resp.getWriter().print(JSON.toString(categoryList));
    resp.getWriter().flush();
}
 
开发者ID:brosander,项目名称:kettle-plugins,代码行数:26,代码来源:KThinJobEntryListServlet.java


示例3: getJobEntryDialog

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public JobEntryDialogInterface getJobEntryDialog(JobEntryInterface jobEntryInterface, JobMeta jobMeta)
{
	PluginRegistry registry = PluginRegistry.getInstance();
	String dialogClassName = jobEntryInterface.getDialogClassName();
	try
	{
		Class<?> dialogClass;
		Class<?>[] paramClasses = new Class[] { spoon.getShell().getClass(), JobEntryInterface.class,
				Repository.class, JobMeta.class };
		Object[] paramArgs = new Object[] { spoon.getShell(), jobEntryInterface, spoon.getRepository(), jobMeta };
		Constructor<?> dialogConstructor;
		
		PluginInterface plugin = registry.getPlugin(JobEntryPluginType.class, jobEntryInterface);
		dialogClass = PluginRegistry.getInstance().getClass(plugin, dialogClassName);
		dialogConstructor = dialogClass.getConstructor(paramClasses);
		return (JobEntryDialogInterface) dialogConstructor.newInstance(paramArgs);
	} catch (Throwable t)
	{
		t.printStackTrace();
		spoon.getLog().logError(spoon.toString(), "Could not create dialog for " + dialogClassName, t);
	}
	return null;
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:24,代码来源:SpoonJobDelegate.java


示例4: init

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的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


示例5: loadEntryImages

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
private Map<String, SwingUniversalImage> loadEntryImages() {
  Map<String, SwingUniversalImage> map = new HashMap<>();

  for ( PluginInterface plugin : PluginRegistry.getInstance().getPlugins( JobEntryPluginType.class ) ) {
    try {
      if ( JobMeta.STRING_SPECIAL.equals( plugin.getIds()[0] ) ) {
        continue;
      }

      SwingUniversalImage image = getUniversalImageIcon( plugin );
      if ( image == null ) {
        throw new KettleException( "Unable to find image file: "
          + plugin.getImageFile() + " for plugin: " + plugin );
      }

      map.put( plugin.getIds()[0], image );
    } catch ( Exception e ) {
      log.logError( "Unable to load job entry icon image for plugin: "
        + plugin.getName() + " (id=" + plugin.getIds()[0] + ")", e );
    }
  }

  return map;
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:25,代码来源:SwingGUIResource.java


示例6: init

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的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.JobEntryPluginType; //导入依赖的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: doGet

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
@Override
public void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
    resp.setContentType("image/png");
    String id = req.getParameter("name");
    OutputStream outputStream = resp.getOutputStream();
    final InputStream image;
    if (JobMeta.STRING_SPECIAL_START.equals(id)) {
        image = getResource(BasePropertyHandler.getProperty("STR_image"));
    } else if (JobMeta.STRING_SPECIAL_DUMMY.equals(id)) {
        image = getResource(BasePropertyHandler.getProperty("DUM_image"));
    } else {
        PluginInterface pluginInterface = images.get(id);
        if (pluginInterface == null) {
            for (PluginInterface pluginInterface1 : registry.getPlugins(JobEntryPluginType.class)) {
                if (pluginInterface1.getIds()[0].equalsIgnoreCase(id)) {
                    pluginInterface = pluginInterface1;
                }
            }
        }
        try {
            image = getImage(pluginInterface);
        } catch (KettlePluginException e) {
            throw new ServletException(e);
        }
    }
    IOUtils.copy(image, outputStream);
    outputStream.flush();
}
 
开发者ID:brosander,项目名称:kettle-plugins,代码行数:29,代码来源:KThinJobEntryImageServlet.java


示例9: JobEntryCopy

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public JobEntryCopy(Node entrynode, List<DatabaseMeta> databases, List<SlaveServer> slaveServers, Repository rep) throws KettleXMLException
{
	try
	{
		String stype = XMLHandler.getTagValue(entrynode, "type");
		PluginRegistry registry = PluginRegistry.getInstance();
		PluginInterface jobPlugin = registry.findPluginWithId(JobEntryPluginType.class, stype);
		if (jobPlugin == null)
			throw new KettleStepLoaderException("No valid step/plugin specified (jobPlugin=null) for " + stype);

		// Get an empty JobEntry of the appropriate class...
		entry = (JobEntryInterface) registry.loadClass(jobPlugin, JobEntryInterface.class);
		if (entry != null)
		{
			// System.out.println("New JobEntryInterface built of type:
			// "+entry.getTypeDesc());
			entry.setPluginId(jobPlugin.getIds()[0]);
			entry.loadXML(entrynode, databases, slaveServers, rep);

			// Handle GUI information: nr & location?
			setNr(Const.toInt(XMLHandler.getTagValue(entrynode, "nr"), 0));
			setLaunchingInParallel("Y".equalsIgnoreCase(XMLHandler.getTagValue(entrynode, "parallel")));
			setDrawn("Y".equalsIgnoreCase(XMLHandler.getTagValue(entrynode, "draw")));
			int x = Const.toInt(XMLHandler.getTagValue(entrynode, "xloc"), 0);
			int y = Const.toInt(XMLHandler.getTagValue(entrynode, "yloc"), 0);
			setLocation(x, y);
		}
	} catch (Throwable e)
	{
		String message = "Unable to read Job Entry copy info from XML node : " + e.toString();
		throw new KettleXMLException(message, e);
	}
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:34,代码来源:JobEntryCopy.java


示例10: setEntry

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public void setEntry(JobEntryInterface je)
{
	entry = je;
	if (entry!=null)
	{
		if (entry.getPluginId()==null)
	    {
			entry.setPluginId( PluginRegistry.getInstance().getPluginId(JobEntryPluginType.class, entry) );
		  }
	}
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:12,代码来源:JobEntryCopy.java


示例11: setShellImage

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public static final void setShellImage(Shell shell, JobEntryInterface jobEntryInterface)
{
    try
    {
        String id = PluginRegistry.getInstance().getPluginId(JobEntryPluginType.class, jobEntryInterface);
        if (id!=null)
        {
            shell.setImage((Image) GUIResource.getInstance().getImagesJobentries().get(id));
        }
    }
    catch(Throwable e)
    {
    }
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:15,代码来源:JobDialog.java


示例12: helpShowJobEntryPlugins

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
/**
 * Show a dialog containing information on the different job entry plugins.
 */
public void helpShowJobEntryPlugins() {
  RowBuffer rowBuffer = PluginRegistry.getInstance().getPluginInformation(JobEntryPluginType.class);
  PreviewRowsDialog dialog = new PreviewRowsDialog(shell, null, SWT.NONE, null, rowBuffer.getRowMeta(), rowBuffer
      .getBuffer());
  dialog.setTitleMessage(BaseMessages.getString(PKG, "Spoon.Dialog.JobEntryPluginList.Title"), BaseMessages
      .getString(PKG, "Spoon.Dialog.JobEntryPluginList.Message"));
  dialog.open();
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:12,代码来源:Spoon.java


示例13: loadEntryImages

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
private Map<String, BufferedImage> loadEntryImages() throws KettleException {
	Map<String, BufferedImage> map = new HashMap<String, BufferedImage>();
	
	for (PluginInterface plugin : PluginRegistry.getInstance().getPlugins(JobEntryPluginType.class)) {
	  try {
 			if ("SPECIAL".equals(plugin.getIds()[0])) {
 				continue;
 			}
 			
 			String imageFile = plugin.getImageFile();
 			if (imageFile==null) {
 				throw new KettleException("No image file (icon) specified for plugin: "+plugin);
 			}

 			BufferedImage image = getImageIcon(plugin);
 			if (image==null) {
 				throw new KettleException("Unable to find image file: "+plugin.getImageFile()+" for plugin: "+plugin);
 			}
 			if (image.getHeight(null)<0) {
 				image = getImageIcon(plugin);
 				if (image==null || image.getHeight(null)<0) {
 					throw new KettleException("Unable to load image file: "+plugin.getImageFile()+" for plugin: "+plugin);
 				}
 			}
 			
 			map.put(plugin.getIds()[0], image);
     } catch(Exception e) {
       log.logError("Unable to load job entry icon image for plugin: "+plugin.getName()+" (id="+plugin.getIds()[0], e);
     }
	}
	
	return map;
}
 
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:34,代码来源:SwingGUIResource.java


示例14: detectPluginFolderPath

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
private static String detectPluginFolderPath() {
    try {
        final PluginInterface spoonPlugin = PluginRegistry.getInstance().findPluginWithId(JobEntryPluginType.class,
                "DataCleanerJobEntry");
        return KettleVFS.getFilename(KettleVFS.getFileObject(spoonPlugin.getPluginDirectory().toString()));
    } catch (Exception e) {
        throw new RuntimeException(
                "Unable to determine location of the spoon profile plugin. It is needed to know where DataCleaner is installed.");
    }
}
 
开发者ID:datacleaner,项目名称:pdi-datacleaner,代码行数:11,代码来源:DataCleanerSpoonConfiguration.java


示例15: JobEntryCopy

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public JobEntryCopy(Node entrynode, List<DatabaseMeta> databases, List<SlaveServer> slaveServers, Repository rep) throws KettleXMLException
{
	try
	{
		String stype = XMLHandler.getTagValue(entrynode, "type");
		PluginRegistry registry = PluginRegistry.getInstance();
		PluginInterface jobPlugin = registry.findPluginWithId(JobEntryPluginType.class, stype);
		if (jobPlugin == null)
			throw new KettleStepLoaderException("No valid step/plugin specified (jobPlugin=null) for " + stype);

		// Get an empty JobEntry of the appropriate class...
		entry = (JobEntryInterface) registry.loadClass(jobPlugin, JobEntryInterface.class);
		if (entry != null)
		{
			// System.out.println("New JobEntryInterface built of type:
			// "+entry.getTypeDesc());
			entry.setPluginId(jobPlugin.getIds()[0]);
			entry.loadXML(entrynode, databases, slaveServers, rep);

			// Handle GUI information: nr & location?
			setNr(Const.toInt(XMLHandler.getTagValue(entrynode, "nr"), 0));
			setLaunchingInParallel("Y".equalsIgnoreCase(XMLHandler.getTagValue(entrynode, "parallel")));
			setDrawn("Y".equalsIgnoreCase(XMLHandler.getTagValue(entrynode, "draw")));
			int x = Const.toInt(XMLHandler.getTagValue(entrynode, "xloc"), 0);
			int y = Const.toInt(XMLHandler.getTagValue(entrynode, "yloc"), 0);
			setLocation(x, y);
       setCheckpoint("Y".equalsIgnoreCase(XMLHandler.getTagValue(entrynode, "checkpoint")));
		}
	} catch (Throwable e)
	{
		String message = "Unable to read Job Entry copy info from XML node : " + e.toString();
		throw new KettleXMLException(message, e);
	}
}
 
开发者ID:jjeb,项目名称:kettle-trunk,代码行数:35,代码来源:JobEntryCopy.java


示例16: setShellImage

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public static final void setShellImage(Shell shell,
JobEntryInterface jobEntryInterface) {
   try {
     final PluginInterface plugin = PluginRegistry.getInstance().getPlugin(JobEntryPluginType.class, jobEntryInterface);
     if (!Const.isEmpty(plugin.getDocumentationUrl())) {
       BaseStepDialog.createHelpButton(shell, "Documentation for job entry "+jobEntryInterface.getName(), plugin);
     }

     String id = plugin.getIds()[0];
     if (id != null) {
       shell.setImage((Image) GUIResource.getInstance().getImagesJobentries().get(id));
     }
   } catch (Throwable e) {
   }
 }
 
开发者ID:jjeb,项目名称:kettle-trunk,代码行数:16,代码来源:JobDialog.java


示例17: JobEntryCopy

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public JobEntryCopy( Node entrynode, List<DatabaseMeta> databases, List<SlaveServer> slaveServers, Repository rep,
    IMetaStore metaStore ) throws KettleXMLException {
  try {
    String stype = XMLHandler.getTagValue( entrynode, "type" );
    PluginRegistry registry = PluginRegistry.getInstance();
    PluginInterface jobPlugin = registry.findPluginWithId( JobEntryPluginType.class, stype );
    if ( jobPlugin == null ) {
      String name = XMLHandler.getTagValue( entrynode, "name" );
      entry = new MissingEntry( name, stype );
    } else {
      entry = registry.loadClass( jobPlugin, JobEntryInterface.class );
    }
    // Get an empty JobEntry of the appropriate class...
    if ( entry != null ) {
      // System.out.println("New JobEntryInterface built of type:
      // "+entry.getTypeDesc());
      if ( jobPlugin != null ) {
        entry.setPluginId( jobPlugin.getIds()[0] );
      }
      entry.setMetaStore( metaStore ); // inject metastore
      entry.loadXML( entrynode, databases, slaveServers, rep, metaStore );
      compatibleLoadXml( entrynode, databases, slaveServers, rep );

      // Handle GUI information: nr & location?
      setNr( Const.toInt( XMLHandler.getTagValue( entrynode, "nr" ), 0 ) );
      setLaunchingInParallel( "Y".equalsIgnoreCase( XMLHandler.getTagValue( entrynode, "parallel" ) ) );
      setDrawn( "Y".equalsIgnoreCase( XMLHandler.getTagValue( entrynode, "draw" ) ) );
      int x = Const.toInt( XMLHandler.getTagValue( entrynode, "xloc" ), 0 );
      int y = Const.toInt( XMLHandler.getTagValue( entrynode, "yloc" ), 0 );
      setLocation( x, y );

      attributesMap = AttributesUtil.loadAttributes( XMLHandler.getSubNode( entrynode, AttributesUtil.XML_TAG ) );
    }
  } catch ( Throwable e ) {
    String message = "Unable to read Job Entry copy info from XML node : " + e.toString();
    throw new KettleXMLException( message, e );
  }
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:39,代码来源:JobEntryCopy.java


示例18: setEntry

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public void setEntry( JobEntryInterface je ) {
  entry = je;
  if ( entry != null ) {
    if ( entry.getPluginId() == null ) {
      entry.setPluginId( PluginRegistry.getInstance().getPluginId( JobEntryPluginType.class, entry ) );
    }
  }
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:9,代码来源:JobEntryCopy.java


示例19: getJobEntryDialog

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public JobEntryDialogInterface getJobEntryDialog( JobEntryInterface jobEntryInterface, JobMeta jobMeta ) {
  PluginRegistry registry = PluginRegistry.getInstance();
  String dialogClassName = jobEntryInterface.getDialogClassName();
  try {
    Class<?> dialogClass;
    Class<?>[] paramClasses =
      new Class<?>[] { spoon.getShell().getClass(), JobEntryInterface.class, Repository.class, JobMeta.class };
    Object[] paramArgs = new Object[] { spoon.getShell(), jobEntryInterface, spoon.getRepository(), jobMeta };
    Constructor<?> dialogConstructor;

    try {
      PluginInterface plugin = registry.getPlugin( JobEntryPluginType.class, jobEntryInterface );
      dialogClass = PluginRegistry.getInstance().getClass( plugin, dialogClassName );
    } catch ( Exception e ) {
      dialogClass = Class.forName( dialogClassName, true, jobEntryInterface.getClass().getClassLoader() );
    }
    dialogConstructor = dialogClass.getConstructor( paramClasses );
    JobEntryDialogInterface entryDialogInterface =
      (JobEntryDialogInterface) dialogConstructor.newInstance( paramArgs );
    entryDialogInterface.setMetaStore( spoon.getMetaStore() );
    return entryDialogInterface;
  } catch ( Throwable t ) {
    t.printStackTrace();
    spoon.getLog().logError( spoon.toString(), "Could not create dialog for " + dialogClassName, t );
    return null;
  }
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:28,代码来源:SpoonJobDelegate.java


示例20: helpJobEntry

import org.pentaho.di.core.plugins.JobEntryPluginType; //导入依赖的package包/类
public void helpJobEntry() {
  final JobEntryCopy jobEntry = (JobEntryCopy) selectionObject;
  String jobName = jobEntry.getName();
  PluginInterface jobEntryPlugin =
    PluginRegistry.getInstance().findPluginWithName( JobEntryPluginType.class, jobName );
  HelpUtils.openHelpDialog( shell, jobEntryPlugin );
}
 
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:8,代码来源:Spoon.java



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


鲜花

握手

雷人

路过

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

请发表评论

全部评论

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

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

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

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

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