Kettle 使用Json输入

 import java.math.BigDecimal; private static final String JD="jd"; private static final String WD="wd"; public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException{ ???????if(first) { ???????????first = false; ???????} ???????Object[] r = getRow(); ???????if (r == null) { ???????????setOutputDone(); ???????????return false; ???????} ???????//维度 ???????String wdstr = get(Fields.In, WD).getString(r); ???????//经度 ???????String jdstr = get(Fields.In, JD).getString(r); ???????if(!isArray(wdstr)||!isArray(jdstr)){ ??????????return true; ???????} ???????get(Fields.Out, WD).setValue(r, getCovNewVlaue(wdstr)); ???????get(Fields.Out, JD).setValue(r, getCovNewVlaue(jdstr)); ???????putRow(data.outputRowMeta, r); ???????return true; ?} private double getCovNewVlaue(String dustr) { ???????String replace = ?dustr.replace("N", "").replace("E", ""); ???????String[] duArray = replace.split(" "); ???????double duValue = Double.parseDouble(duArray[0]); ???????double minuteValue = Double.parseDouble(duArray[1]); ???????double secondValue = Double.parseDouble(duArray[2]); ???????BigDecimal minute = BigDecimal.valueOf(minuteValue).divide(BigDecimal.valueOf(60), 10, ???????????????BigDecimal.ROUND_HALF_DOWN); ???????BigDecimal second = BigDecimal.valueOf(secondValue).divide(BigDecimal.valueOf(3600), 10, ???????????????BigDecimal.ROUND_HALF_DOWN); ???????BigDecimal newVlaue = BigDecimal.valueOf(duValue).add(minute).add(second); ???????return newVlaue.doubleValue(); ???} private boolean isArray(String dustr){ ???????return dustr.split(" ").length==1?false:true; }