文档章节

User Defined Java Class

熊爸爸
 熊爸爸
发布于 2016/09/06 10:06
字数 190
阅读 19
收藏 0

import org.pentaho.di.trans.steps.userdefinedjavaclass.*;
import org.pentaho.di.trans.step.*;
import org.pentaho.di.core.row.*;
import org.pentaho.di.core.*;
import org.pentaho.di.core.exception.*;

String TransField;
String DbParamField;
int firstsign;
int lastsign;

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException
{
    // First, get a row from the default input hop
    //
    Object[] r = getRow();

    // If the row object is null, we are done processing.
    //
    if (r == null) {
      setOutputDone();
      return false;
    }

    // Let's look up parameters only once for performance reason.
    //
    if (first) {
      TransField = getParameter("Trans");
      DbParamField = getParameter("DbParam");
      first=false;
    }

    // It is always safest to call createOutputRow() to ensure that your output row's Object[] is large
    // enough to handle any new fields you are creating in this step.
    //
    Object[] outputRow = createOutputRow(r, data.outputRowMeta.size());

    String Trans = get(Fields.In, "Trans").getString(r);
    String DbParam = get(Fields.In, "DbParam").getString(r);

    //add by wangyong 2013-11-11
    firstsign = Trans.indexOf("/");
    lastsign = Trans.lastIndexOf("/");
    DbParam = Trans.substring(0,firstsign)+":"+DbParam;
    String Path = Trans.substring(0,lastsign);
    Trans = Trans.substring(lastsign+1);

    // Set the value in the output field
    //
    get(Fields.Out, "Path").setValue(outputRow, Path);
    get(Fields.Out, "Trans").setValue(outputRow, Trans);
    get(Fields.Out, "DbParam").setValue(outputRow, DbParam);

    // putRow will send the row on to the default output hop.
    //
    putRow(data.outputRowMeta, outputRow);

    return true;
}
 

© 著作权归作者所有

熊爸爸

熊爸爸

粉丝 1
博文 23
码字总数 441
作品 0
浦东
高级程序员
私信 提问
Play! 1.1 框架中的 Scala 模块

Play! 1.1 包含了对 Scala 编程语言的支持,由于 Play 框架的灵活性,使得通过一个简单的模块即可支持 Scala ,要启用 Scala 支持只需要在 conf/application.conf 文件中配置: 接下来就可以...

红薯
2011/01/11
1K
3
Kettle中怎么使用User Defined Java Class?主要是左侧的Input Fields一直现实please wait

初次使用Kettle做数据抽取和转换。其中有些数据需要比较复杂的计算来生成新的一列。想使用User Defined Java Class试试,可是在User Defined Java Class中,左侧老是显示如下图 然后就不知道...

叫悟空的猴子
2014/02/15
1K
2
android jni回调 转自http://android.wooyd.org/JNIExa...

Important notice<注意> The instructions in these document are applicable to older Android firmwares. Starting with firmware version 1.5 the Android NDK has been released, which......

貌似高手
2012/07/06
399
1
数据库、JDBC、Java数据类型

MS SQL SERVER 2012: http://technet.microsoft.com/en-us/library/ms378599(v=sql.110).aspx 基本类型映射: SQL Server Types JDBC Types (java.sql.Types) Java Language Types bigint BI......

YuanyuanL
2014/10/14
97
0
Tomcat tomcat-users.xml configuration example

This article describes the configuration of the tomcat-users.xml file forApache Tomcat 7 web server. tomcat-users.xml is the default user database for container-managed authenti......

五大三粗
2015/11/16
61
0

没有更多内容

加载失败,请刷新页面

加载更多

Echars鼠标点击事件多次触发

本文转载于:专业的前端网站➭Echars鼠标点击事件多次触发 gChart.on('click', function (params) { if (params.componentSubType == "bar" && params.componentType == "serie......

前端老手
3分钟前
1
0
springboot2.0.6(附) 解析META-INF/spring.factories通过系统加载类获取对应的 class 的全限定名称

在 SpringBoot中是通过getSpringFactoriesInstances(Class<T> type)方法获取所有classpath下面的META-INF/spring.factories文件,然后根据type值找到对应的 class 的全限定名称列表。下面我来...

小亮89
4分钟前
1
0
zk工厂方法实现NIOServerCnxnFactory

NIOServerCnxnFactory类 内部类 AbstractSelectThread AcceptThread SelectorThread 属性 ZOOKEEPER_NIO_SESSIONLESS_CNXN_TIMEOUT 10s session过期时间 ZOOKEEPER_NIO_NUM_SELECTOR_THREADS......

writeademo
8分钟前
2
0
天猫精灵业务如何使用机器学习PAI进行模型推理优化

作者:如切,悟双,楚哲,晓祥,旭林 引言 天猫精灵(TmallGenie)是阿里巴巴人工智能实验室(Alibaba A.I.Labs)于2017年7月5日发布的AI智能语音终端设备。天猫精灵目前是全球销量第三、中国...

阿里云官方博客
16分钟前
2
0
BJL技巧之大路馆擦法—《利辰逸》

很多朋友刚玩百佳时间不长,不知道如何看路,今 天我就来简单的讲下看大路的方法。 都是前辈教的,这里我只是简单复述一下。 大路的观察方法有以下几种: 先从庄闲的数量变化说起。 庄闲的强...

那女孩对我说
16分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部