Package org.pentaho.di.trans.steps.mergerows

Class MergeRowsHelper

java.lang.Object

org.pentaho.di.trans.step.BaseStepHelper

org.pentaho.di.trans.steps.mergerows.MergeRowsHelper

All Implemented Interfaces:

StepHelperInterface

public class MergeRowsHelper
extends BaseStepHelper
implements StepHelperInterface

Helper class for the Merge Rows step

Provides step-specific actions and utilities for the Merge Rows step, such as retrieving reference step fields.

Field Summary

Fields inherited from class org.pentaho.di.trans.step.BaseStepHelper

IS_TRANS_REFERENCE, IS_VALID_REFERENCE, log, REFERENCE_PATH, SEPARATOR

Fields inherited from interface org.pentaho.di.trans.step.StepHelperInterface

ACTION_STATUS, FAILURE_METHOD_NOT_FOUND_RESPONSE, FAILURE_RESPONSE, STATUS, SUCCESS_RESPONSE

Constructor Summary

Constructors

Constructor	Description
MergeRowsHelper(MergeRowsMeta mergeRowsMeta)

Method Summary

Modifier and Type	Method	Description
org.json.simple.JSONObject	getReferenceStepsFields(TransMeta transMeta)	Retrieves the field names from the reference step (first info stream) for MergeRows.
protected org.json.simple.JSONObject	handleStepAction(String method, TransMeta transMeta, Map<String,String> queryParams)	Handles step-specific actions for MergeRows.

Methods inherited from class org.pentaho.di.trans.step.BaseStepHelper

getReferencePath, isFailedResponse, stepAction, validateAndPutReferenceStatus

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.pentaho.di.trans.step.StepHelperInterface

stepAction

Constructor Details

MergeRowsHelper

public MergeRowsHelper(MergeRowsMeta mergeRowsMeta)

Method Details

handleStepAction

protected org.json.simple.JSONObject handleStepAction(String method,
 TransMeta transMeta,
 Map<String,String> queryParams)

Handles step-specific actions for MergeRows.

Specified by:

handleStepAction in class BaseStepHelper

Parameters:

method - the action method name

transMeta - the transformation metadata

queryParams - additional query parameters

Returns:

a JSON object containing the response

getReferenceStepsFields

public org.json.simple.JSONObject getReferenceStepsFields(TransMeta transMeta)
                                                   throws org.pentaho.di.core.exception.KettleException

Retrieves the field names from the reference step (first info stream) for MergeRows.

Parameters:

transMeta - the transformation metadata

Returns:

a JSON object containing the field names under the key "stepFieldsNames"

Throws:

org.pentaho.di.core.exception.KettleException - if an error occurs while retrieving the fields