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