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();
// 如果输入行为空,则返回 false
if (rowData == null) {
setOutputDone();
return false;
}
// 获取文本文件内容(假设内容在第一个字段中)
String fileContent = rowData[0].toString();
logBasic("数据是: " +fileContent.toUpperCase());
// 处理完成,返回 true
return true;
}
运行,查看结果
把小写转换为大写了