用 Kettle UDJC 组件实现用户行为组序列

private String diffListId = "";
private String diffFuncNo = "";
private int fieldSeq = 0;

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException
{
    Object[] r = getRow();

    if (r == null) {
        setOutputDone();
        return false;
    }

    if (first) {
        first = false;
    }

    r = createOutputRow(r, data.outputRowMeta.size());
    
    // Get the value from an input field
    String fieldListId = get(Fields.In, "LIST_ID").getString(r);
    String fieldFuncNo = get(Fields.In, "FUNC_NO").getString(r);

    if (!diffListId.equals(fieldListId) || fieldFuncNo.equals("PU001")) {
        diffListId = fieldListId;
        fieldSeq++;
    }
    
    
    // Set a value in a new output field
    get(Fields.Out, "SEQ").setValue(r, fieldSeq);

    // Send the row on to the next step.
    putRow(data.outputRowMeta, r);

    return true;
}