kettle9.4
用到两个组件
文本文件输入
文件内容如下
文本文件输入---文件
文本文件输入---内容
注意事项:分隔符这里,我一直没注意,导致不管怎么读数据都读不到;可以用换行符,可以用其他的,视情况而定;
到这里,文本文件输入组件的部分结束了;
java代码组件
跟普通的java类不一样,没有类的申明,只有方法在里面!!
getRow()是kettle的自己的方法,是获取行的意思;
import org.pentaho.di.core.exception.KettleException;
import org.pentaho.di.trans.step.StepMetaInterface;
import org.pentaho.di.core.row.RowMetaInterface;
public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {// 获取输入行数据Object[] rowData = getRow();// 如果输入行为空,则返回 falseif (rowData == null) {setOutputDone();return false;}// 获取文本文件内容(假设内容在第一个字段中)String fileContent = rowData[0].toString();logBasic("数据是: " +fileContent.toUpperCase());// 处理完成,返回 truereturn true;
}
运行,查看结果
把小写转换为大写了