本文整理匯總了Java中org.pentaho.di.core.row.RowDataUtil.addRowData方法的典型用法代碼示例。如果您正苦於以下問題：Java RowDataUtil.addRowData方法的具體用法？Java RowDataUtil.addRowData怎麽用？Java RowDataUtil.addRowData使用的例子？那麽恭喜您, 這裏精選的方法代碼示例或許可以為您提供幫助。您也可以進一步了解該方法所在類org.pentaho.di.core.row.RowDataUtil的用法示例。

在下文中一共展示了RowDataUtil.addRowData方法的16個代碼示例，這些例子默認根據受歡迎程度排序。您可以為喜歡或者感覺有用的代碼點讚，您的評價將有助於我們的係統推薦出更棒的Java代碼示例。

示例1: buildResult

​點讚 4

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

private Object[] buildResult(Object[] r) throws KettleValueException

{

Object[] result=null;

if (r!=null || meta.isAlwaysGivingBackOneRow()) {

result = RowDataUtil.allocateRowData(data.groupnrs.length);

if (r!=null)

{

for (int i=0;i

{

result[i]=r[data.groupnrs[i]];

}

}

result=RowDataUtil.addRowData(result, data.groupnrs.length, getAggregateResult());

}

return result;

}

開發者ID:icholy，項目名稱:geokettle-2.0，代碼行數:19，

示例2: lookupValues

​點讚 3

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

private Object[] lookupValues(RowMetaInterface rowMeta, Object[] row) throws KettleException

{

if (first) {

first=false;

data.outputRowMeta = getInputRowMeta().clone();

meta.getFields(data.outputRowMeta, getStepname(), new RowMetaInterface[] { data.infoMeta }, null, this);

// Check lookup field

data.indexOfMainField = getInputRowMeta().indexOfValue(environmentSubstitute(meta.getMainStreamField()));

if (data.indexOfMainField<0) {

// The field is unreachable !

throw new KettleException(BaseMessages.getString(PKG, "FuzzyMatch.Exception.CouldnotFindMainField",meta.getMainStreamField())); //$NON-NLS-1$ //$NON-NLS-2$

}

}

Object[] add = null;

try {

add=getFromCache(row);

} catch(Exception e) {

throw new KettleStepException(e);

}

return RowDataUtil.addRowData(row, rowMeta.size(), add);

}

開發者ID:yintaoxue，項目名稱:read-open-source-code，代碼行數:25，

示例3: processRow

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException

{

Object[] r=null;

r = getRow();

if (r==null) // no more rows to be expected from the previous step(s)

{

setOutputDone();

return false;

}

if ( data.firstRow )

{

// The output meta is the original input meta + the

// additional constant fields.

data.firstRow = false;

data.outputMeta = getInputRowMeta().clone();

RowMetaInterface constants = data.constants.getRowMeta();

data.outputMeta.mergeRowMeta(constants);

}

// Add the constant data to the end of the row.

r = RowDataUtil.addRowData(r, getInputRowMeta().size(), data.constants.getData());

putRow(data.outputMeta, r);

if (log.isRowLevel())

{

log.logRowlevel(toString(), Messages.getString("Constant.Log.Wrote.Row", Long.toString(getLinesWritten()), getInputRowMeta().getString(r)) );

}

if (checkFeedback(getLinesWritten()))

{

if(log.isBasic()) logBasic( Messages.getString("Constant.Log.LineNr", Long.toString(getLinesWritten()) ));

}

return true;

}

開發者ID:icholy，項目名稱:geokettle-2.0，代碼行數:41，

示例4: processQueueObjectAt

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

public void processQueueObjectAt(int i) throws KettleStepException {

int index = i - 1;

Object[] rows = data.data.toArray();

Object[] fields = new Object[meta.getNumberOfFields()];

for ( int j = 0 ; j < meta.getNumberOfFields(); j++ ) {

// field_index is the location inside a row of the subject of this

// ie, ORDERTOTAL might be the subject ofthis field lag or lead

// so we determine that ORDERTOTAL's index in the row

int field_index = data.inputRowMeta.indexOfValue(meta.getSubjectField()[j]);

int row_index = 0;

switch(meta.getAggregateType()[j])

{

case AnalyticQueryMeta.TYPE_FUNCT_LAG :

row_index = index - meta.getValueField()[j];

break;

case AnalyticQueryMeta.TYPE_FUNCT_LEAD :

row_index = index + meta.getValueField()[j];

break;

default: break;

}

if ( row_index < rows.length && row_index >= 0 ){

Object[] singleRow = (Object[]) rows[row_index];

if ( singleRow != null && singleRow[field_index] != null ) {

fields[j] = ((Object []) rows[row_index])[field_index];

}else {

// set default

fields[j] = null;

}

} else {

// set default

fields[j] = null;

}

}

Object[] newRow = RowDataUtil.addRowData((Object []) rows[index], data.inputRowMeta.size(), fields);

putRow(data.outputRowMeta, newRow);

}

開發者ID:icholy，項目名稱:geokettle-2.0，代碼行數:41，

示例5: readStartDate

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

private synchronized RowMetaAndData readStartDate() throws KettleException

{

if (log.isDetailed()) logDetailed("Reading from step [" + meta.getLookupStepname() + "]");

RowMetaInterface parametersMeta = new RowMeta();

Object[] parametersData = new Object[] {};

RowSet rowSet = findInputRowSet(meta.getLookupStepname());

if (rowSet!=null)

{

Object[] rowData = getRowFrom(rowSet); // rows are originating from "lookup_from"

while (rowData!=null)

{

parametersData = RowDataUtil.addRowData(parametersData, parametersMeta.size(), rowData);

parametersMeta.addRowMeta(rowSet.getRowMeta());

rowData = getRowFrom(rowSet); // take all input rows if needed!

}

if (parametersMeta.size()==0)

{

throw new KettleException("Expected to read parameters from step ["+meta.getLookupStepname()+"] but none were found.");

}

}

else

{

throw new KettleException("Unable to find rowset to read from, perhaps step ["+meta.getLookupStepname()+"] doesn't exist. (or perhaps you are trying a preview?)");

}

RowMetaAndData parameters = new RowMetaAndData(parametersMeta, parametersData);

return parameters;

}

開發者ID:icholy，項目名稱:geokettle-2.0，代碼行數:34，

示例6: processRow

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException

{

Object[] r=null;

r = getRow();

if (r==null) // no more rows to be expected from the previous step(s)

{

setOutputDone();

return false;

}

if ( data.firstRow )

{

// The output meta is the original input meta + the

// additional constant fields.

data.firstRow = false;

data.outputMeta = getInputRowMeta().clone();

RowMetaInterface constants = data.constants.getRowMeta();

data.outputMeta.mergeRowMeta(constants);

}

// Add the constant data to the end of the row.

r = RowDataUtil.addRowData(r, getInputRowMeta().size(), data.constants.getData());

putRow(data.outputMeta, r);

if (log.isRowLevel())

{

logRowlevel(BaseMessages.getString(PKG, "Constant.Log.Wrote.Row", Long.toString(getLinesWritten()), getInputRowMeta().getString(r)) );

}

if (checkFeedback(getLinesWritten()))

{

if(log.isBasic()) logBasic( BaseMessages.getString(PKG, "Constant.Log.LineNr", Long.toString(getLinesWritten()) ));

}

return true;

}

開發者ID:yintaoxue，項目名稱:read-open-source-code，代碼行數:41，

示例7: readStartDate

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

private RowMetaAndData readStartDate() throws KettleException

{

if (log.isDetailed()) logDetailed("Reading from step [" + data.infoStream.getStepname() + "]");

RowMetaInterface parametersMeta = new RowMeta();

Object[] parametersData = new Object[] {};

RowSet rowSet = findInputRowSet(data.infoStream.getStepname());

if (rowSet!=null)

{

Object[] rowData = getRowFrom(rowSet); // rows are originating from "lookup_from"

while (rowData!=null)

{

parametersData = RowDataUtil.addRowData(parametersData, parametersMeta.size(), rowData);

parametersMeta.addRowMeta(rowSet.getRowMeta());

rowData = getRowFrom(rowSet); // take all input rows if needed!

}

if (parametersMeta.size()==0)

{

throw new KettleException("Expected to read parameters from step ["+data.infoStream.getStepname()+"] but none were found.");

}

}

else

{

throw new KettleException("Unable to find rowset to read from, perhaps step ["+data.infoStream.getStepname()+"] doesn't exist. (or perhaps you are trying a preview?)");

}

RowMetaAndData parameters = new RowMetaAndData(parametersMeta, parametersData);

return parameters;

}

開發者ID:yintaoxue，項目名稱:read-open-source-code，代碼行數:34，

示例8: processRow

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

public boolean processRow( StepMetaInterface smi, StepDataInterface sdi ) throws KettleException {

meta = (GetSessionVariableMeta) smi;

data = (GetSessionVariableData) sdi;

Object[] rowData;

// no row data input from previous steps

if ( !data.readsRows ) {

// create a new row

rowData = RowDataUtil.allocateRowData( 0 );

incrementLinesRead();

data.inputRowMeta = new RowMeta();

// get session variables data

getSessionVariablesData();

// add session variables data to row

rowData = RowDataUtil.addRowData( rowData, data.inputRowMeta.size(), data.extraData );

putRow( data.outputRowMeta, rowData );

// end processing

setOutputDone();

return false;

}

// process row

rowData = getRow();

if ( rowData != null ) {

// get session variables data (once)

if ( first ) {

first = false;

data.inputRowMeta = getInputRowMeta();

getSessionVariablesData();

}

// add session variables data to row

rowData = RowDataUtil.addRowData( rowData, data.inputRowMeta.size(), data.extraData );

putRow( data.outputRowMeta, rowData );

// continue

return true;

} else {

// end processing

setOutputDone();

return false;

}

}

開發者ID:pentaho，項目名稱:pdi-platform-utils-plugin，代碼行數:49，

示例9: processRow

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException

{

meta=(DetectLastRowMeta)smi;

data=(DetectLastRowData)sdi;

Object[] r = getRow(); // Get row from input rowset & set row busy!

if(first)

{

if (getInputRowMeta() == null) {

return false;

}

// get the RowMeta

data.previousRowMeta = getInputRowMeta().clone();

data.NrPrevFields = data.previousRowMeta.size();

data.outputRowMeta = data.previousRowMeta;

meta.getFields(data.outputRowMeta, getStepname(), null, null, this);

}

Object[] outputRow=null;

if (r==null) // no more input to be expected...

{

if(previousRow != null)

{

//

// Output the last row with last row indicator set to true.

//

outputRow = RowDataUtil.addRowData(previousRow, getInputRowMeta().size(), data.getTrueArray());

putRow(data.outputRowMeta, outputRow); // copy row to output rowset(s);

if (log.isRowLevel()) {

logRowlevel(Messages.getString("DetectLastRow.Log.WroteRowToNextStep")+data.outputRowMeta.getString(outputRow)); //$NON-NLS-1$

}

if (checkFeedback(getLinesRead())) {

logBasic(Messages.getString("DetectLastRow.Log.LineNumber")+getLinesRead()); //$NON-NLS-1$

}

}

setOutputDone();

return false;

}

if(!first)

{

outputRow = RowDataUtil.addRowData(previousRow, getInputRowMeta().size(), data.getFalseArray());

putRow(data.outputRowMeta, outputRow); // copy row to output rowset(s);

if (log.isRowLevel()) {

logRowlevel(Messages.getString("DetectLastRow.Log.WroteRowToNextStep")+data.outputRowMeta.getString(outputRow)); //$NON-NLS-1$

}

if (checkFeedback(getLinesRead())) {

logBasic(Messages.getString("DetectLastRow.Log.LineNumber")+getLinesRead()); //$NON-NLS-1$

}

}

// keep track of the current row

previousRow = r;

if (first) first = false;

return true;

}

開發者ID:icholy，項目名稱:geokettle-2.0，代碼行數:63，

示例10: processRow

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

/**

* Column number where the input value is stored

*/

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi)

throws KettleException

{

Object[] row = getRow();

if (row == null)

{

setOutputDone();

return false;

}

if (first) {

first = false;

numberRange = new NumberRangeSet(meta.getRules(), meta.getFallBackValue());

data.outputRowMeta = (RowMetaInterface) getInputRowMeta().clone();

// Prepare output fields

meta.getFields(data.outputRowMeta, getStepname(), null, null,this);

// Find column numbers

data.inputColumnNr = data.outputRowMeta.indexOfValue(meta.getInputField());

// Check if a field was not available

if (data.inputColumnNr < 0) {

logError("Field for input could not be found: "+ meta.getInputField());

return false;

}

}

try {

// get field value

String strValue = getInputRowMeta().getString(row,data.inputColumnNr);

// return range

String ranges = numberRange.evaluate(strValue);

// add value to output

row = RowDataUtil.addRowData(row, getInputRowMeta().size(),new Object[] { ranges });

putRow(data.outputRowMeta, row);

if (checkFeedback(getLinesRead()))

{

if(log.isDetailed()) logDetailed(Messages.getString("NumberRange.Log.LineNumber")+getLinesRead()); //$NON-NLS-1$

}

}

catch(KettleException e)

{

boolean sendToErrorRow=false;

String errorMessage = null;

if (getStepMeta().isDoingErrorHandling())

{

sendToErrorRow = true;

errorMessage = e.toString();

}

else

{

logError(Messages.getString("NumberRange.Log.ErrorInStepRunning")+e.getMessage()); //$NON-NLS-1$

setErrors(1);

stopAll();

setOutputDone(); // signal end to receiver(s)

return false;

}

if (sendToErrorRow)

{

// Simply add this row to the error row

putError(getInputRowMeta(), row, 1, errorMessage, null, "NumberRange001");

}

}

return true;

}

開發者ID:icholy，項目名稱:geokettle-2.0，代碼行數:73，

示例11: processRow

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException

{

Object[] rowData;

if (data.readsRows)

{

rowData = getRow();

if (rowData==null)

{

setOutputDone();

return false;

}

}

else

{

rowData=RowDataUtil.allocateRowData(0);

incrementLinesRead();

}

// initialize

if (first && rowData!=null)

{

first=false;

// Make output meta data

//

if (data.readsRows) {

data.inputRowMeta = getInputRowMeta();

}

else {

data.inputRowMeta = new RowMeta();

}

data.outputRowMeta = data.inputRowMeta.clone();

meta.getFields(data.outputRowMeta, getStepname(), null, null, this);

// Create a copy of the output row metadata to do the data conversion...

//

data.conversionMeta = data.outputRowMeta.clone();

for (ValueMetaInterface valueMeta : data.conversionMeta.getValueMetaList()) {

valueMeta.setType(ValueMetaInterface.TYPE_STRING);

}

// Add the variables to the row...

//

// Keep the Object[] for speed. Although this step will always be used in "small" amounts, there's always going to be those cases where performance is required.

//

data.extraData = new Object[meta.getFieldName().length];

for (int i=0;i

{

String newValue = environmentSubstitute(meta.getVariableString()[i]);

if (log.isDetailed()) logDetailed("field ["+meta.getFieldName()[i]+"] has value ["+newValue+"]");

// Convert the data to the desired data type...

//

ValueMetaInterface targetMeta = data.outputRowMeta.getValueMeta(data.inputRowMeta.size()+i);

ValueMetaInterface sourceMeta = data.conversionMeta.getValueMeta(data.inputRowMeta.size()+i); // String type + conversion masks, symbols, trim type, etc

data.extraData[i] = targetMeta.convertData(sourceMeta, newValue);

}

}

rowData = RowDataUtil.addRowData(rowData, data.inputRowMeta.size(), data.extraData);

putRow(data.outputRowMeta, rowData);

if (!data.readsRows) // Just one row and then stop!

{

setOutputDone();

return false;

}

return true;

}

開發者ID:icholy，項目名稱:geokettle-2.0，代碼行數:74，

示例12: processRow

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException

{

meta=(DetectLastRowMeta)smi;

data=(DetectLastRowData)sdi;

Object[] r = getRow(); // Get row from input rowset & set row busy!

if(first)

{

if (getInputRowMeta() == null) {

setOutputDone();

return false;

}

// get the RowMeta

data.previousRowMeta = getInputRowMeta().clone();

data.NrPrevFields = data.previousRowMeta.size();

data.outputRowMeta = data.previousRowMeta;

meta.getFields(data.outputRowMeta, getStepname(), null, null, this);

}

Object[] outputRow=null;

if (r==null) // no more input to be expected...

{

if(previousRow != null)

{

//

// Output the last row with last row indicator set to true.

//

outputRow = RowDataUtil.addRowData(previousRow, getInputRowMeta().size(), data.getTrueArray());

putRow(data.outputRowMeta, outputRow); // copy row to output rowset(s);

if (log.isRowLevel()) {

logRowlevel(BaseMessages.getString(PKG, "DetectLastRow.Log.WroteRowToNextStep")+data.outputRowMeta.getString(outputRow)); //$NON-NLS-1$

}

if (checkFeedback(getLinesRead())) {

logBasic(BaseMessages.getString(PKG, "DetectLastRow.Log.LineNumber")+getLinesRead()); //$NON-NLS-1$

}

}

setOutputDone();

return false;

}

if(!first)

{

outputRow = RowDataUtil.addRowData(previousRow, getInputRowMeta().size(), data.getFalseArray());

putRow(data.outputRowMeta, outputRow); // copy row to output rowset(s);

if (log.isRowLevel()) {

logRowlevel(BaseMessages.getString(PKG, "DetectLastRow.Log.WroteRowToNextStep")+data.outputRowMeta.getString(outputRow)); //$NON-NLS-1$

}

if (checkFeedback(getLinesRead())) {

logBasic(BaseMessages.getString(PKG, "DetectLastRow.Log.LineNumber")+getLinesRead()); //$NON-NLS-1$

}

}

// keep track of the current row

previousRow = r;

if (first) first = false;

return true;

}

開發者ID:yintaoxue，項目名稱:read-open-source-code，代碼行數:65，

示例13: processRow

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

/**

* Column number where the input value is stored

*/

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi)

throws KettleException

{

Object[] row = getRow();

if (row == null)

{

setOutputDone();

return false;

}

if (first) {

first = false;

numberRange = new NumberRangeSet(meta.getRules(), meta.getFallBackValue());

data.outputRowMeta = (RowMetaInterface) getInputRowMeta().clone();

// Prepare output fields

meta.getFields(data.outputRowMeta, getStepname(), null, null,this);

// Find column numbers

data.inputColumnNr = data.outputRowMeta.indexOfValue(meta.getInputField());

// Check if a field was not available

if (data.inputColumnNr < 0) {

logError("Field for input could not be found: "+ meta.getInputField());

return false;

}

}

try {

// get field value

Double value = getInputRowMeta().getNumber(row,data.inputColumnNr);

// return range

String ranges = numberRange.evaluate(value);

// add value to output

row = RowDataUtil.addRowData(row, getInputRowMeta().size(),new Object[] { ranges });

putRow(data.outputRowMeta, row);

if (checkFeedback(getLinesRead()))

{

if(log.isDetailed()) logDetailed(BaseMessages.getString(PKG, "NumberRange.Log.LineNumber")+getLinesRead()); //$NON-NLS-1$

}

}

catch(KettleException e)

{

boolean sendToErrorRow=false;

String errorMessage = null;

if (getStepMeta().isDoingErrorHandling())

{

sendToErrorRow = true;

errorMessage = e.toString();

}

else

{

logError(BaseMessages.getString(PKG, "NumberRange.Log.ErrorInStepRunning")+e.getMessage()); //$NON-NLS-1$

setErrors(1);

stopAll();

setOutputDone(); // signal end to receiver(s)

return false;

}

if (sendToErrorRow)

{

// Simply add this row to the error row

putError(getInputRowMeta(), row, 1, errorMessage, null, "NumberRange001");

}

}

return true;

}

開發者ID:yintaoxue，項目名稱:read-open-source-code，代碼行數:73，

示例14: getRowData

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

private Object[] getRowData() throws KettleException {

// Build an empty row based on the meta-data

Object[] outputRowData=null;

try {

// Create new row...

outputRowData = data.yaml.getRow(data.rowMeta);

if(outputRowData==null) return null;

if(data.readrow!=null) {

outputRowData=RowDataUtil.addRowData(data.readrow, data.totalPreviousFields, outputRowData);

}else {

outputRowData=RowDataUtil.resizeArray(outputRowData, data.totalOutStreamFields);

}

int rowIndex = data.totalOutFields;

// See if we need to add the filename to the row...

if ( meta.includeFilename() && !Const.isEmpty(meta.getFilenameField()) ) {

outputRowData[rowIndex++] = KettleVFS.getFilename(data.file);

}

// See if we need to add the row number to the row...

if (meta.includeRowNumber() && !Const.isEmpty(meta.getRowNumberField())) {

outputRowData[rowIndex++] = new Long(data.rownr);

}

} catch (Exception e) {

boolean sendToErrorRow=false;

String errorMessage=null;

if (getStepMeta().isDoingErrorHandling()) {

sendToErrorRow = true;

errorMessage = e.toString();

} else {

logError(BaseMessages.getString(PKG, "YamlInput.ErrorInStepRunning",e.toString())); //$NON-NLS-1$

setErrors(1);

stopAll();

logError(Const.getStackTracker(e));

setOutputDone(); // signal end to receiver(s)

}

if (sendToErrorRow) {

// Simply add this row to the error row

putError(getInputRowMeta(), outputRowData, 1, errorMessage, null, "YamlInput001");

}

}

return outputRowData;

}

開發者ID:yintaoxue，項目名稱:read-open-source-code，代碼行數:49，

示例15: handleLastOfGroup

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

private void handleLastOfGroup() throws KettleException {

if (meta.passAllRows()) // ALL ROWS

{

if (data.previous!=null)

{

calcAggregate(data.previous);

addToBuffer(data.previous);

}

data.groupResult = getAggregateResult();

Object[] row = getRowFromBuffer();

long lineNr=0;

while (row!=null)

{

int size = data.inputRowMeta.size();

row=RowDataUtil.addRowData(row, size, data.groupResult);

size+=data.groupResult.length;

lineNr++;

if (meta.isAddingLineNrInGroup() && !Const.isEmpty(meta.getLineNrInGroupField()))

{

Object lineNrValue= new Long(lineNr);

// ValueMetaInterface lineNrValueMeta = new ValueMeta(meta.getLineNrInGroupField(), ValueMetaInterface.TYPE_INTEGER);

// lineNrValueMeta.setLength(9);

row=RowDataUtil.addValueData(row, size, lineNrValue);

size++;

}

addCumulativeSums(row);

addCumulativeAverages(row);

putRow(data.outputRowMeta, row);

row = getRowFromBuffer();

}

closeInput();

}

else // JUST THE GROUP + AGGREGATE

{

// Don't forget the last set of rows...

if (data.previous!=null)

{

calcAggregate(data.previous);

}

Object[] result = buildResult(data.previous);

if (result!=null) {

putRow(data.groupAggMeta, result);

}

}

}

開發者ID:yintaoxue，項目名稱:read-open-source-code，代碼行數:52，

示例16: processRow

​點讚 2

​

import org.pentaho.di.core.row.RowDataUtil; //導入方法依賴的package包/類

public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException {

Object[] row;

Object[] rowIn=null;

if (data.readsRows) {

rowIn=getRow();

if (rowIn==null) {

setOutputDone();

return false;

}

if (first){

first=false;

data.prevNrField= getInputRowMeta().size();

data.outputRowMeta = getInputRowMeta().clone();

meta.getFields(data.outputRowMeta, getStepname(), null, null, this);

}

}else {

if (first) {

first = false;

data.outputRowMeta = new RowMeta();

meta.getFields(data.outputRowMeta, getStepname(), null, null,this);

}

}

for(int i=0; i< data.nr && !isStopped(); i++) {

for(int j=0; j

// Create a new row

row = buildEmptyRow();

incrementLinesRead();

int index=0;

try{

// Return secret key

if(meta.isOutputKeyInBinary()) {

row[index++] = data.cryptoTrans[i].generateKey(data.secretKeyLen[i]) ;

}else {

row[index++] = data.cryptoTrans[i].generateKeyAsHex(data.secretKeyLen[i]) ;

}

}catch(CryptoException k) {

throw new KettleException(BaseMessages.getString(PKG,"SecretKeyGenerator.KeyGenerationError", i), k);

}

if(data.addAlgorithmOutput) {

// add algorithm

row[index++]=meta.getAlgorithm()[i];

}

if(data.addSecretKeyLengthOutput) {

// add secret key len

row[index++]= new Long(data.secretKeyLen[i]);

}

if(data.readsRows) {

// build output row

row= RowDataUtil.addRowData(rowIn, data.prevNrField, row);

}

if (isRowLevel()) logRowlevel(BaseMessages.getString(PKG, "SecretKeyGenerator.Log.ValueReturned",data.outputRowMeta.getString(row)));

putRow(data.outputRowMeta, row);

}

}

setOutputDone();

return false;

}

開發者ID:yintaoxue，項目名稱:read-open-source-code，代碼行數:74，

注：本文中的org.pentaho.di.core.row.RowDataUtil.addRowData方法示例整理自Github/MSDocs等源碼及文檔管理平台，相關代碼片段篩選自各路編程大神貢獻的開源項目，源碼版權歸原作者所有，傳播和使用請參考對應項目的License；未經允許，請勿轉載。