Package org.pentaho.di.trans.steps.streamlookup

Class StreamLookupStepHelper

java.lang.Object

org.pentaho.di.trans.step.BaseStepHelper

org.pentaho.di.trans.steps.streamlookup.StreamLookupStepHelper

All Implemented Interfaces:

StepHelperInterface

public class StreamLookupStepHelper
extends BaseStepHelper

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
StreamLookupStepHelper(StreamLookupMeta streamLookupMeta)

Method Summary

Modifier and Type	Method	Description
protected org.json.simple.JSONObject	handleStepAction(String method, TransMeta transMeta, Map<String,String> queryParams)	Handles step actions based on the provided method name.

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

Constructor Details

StreamLookupStepHelper

public StreamLookupStepHelper(StreamLookupMeta streamLookupMeta)

Method Details

handleStepAction

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

Handles step actions based on the provided method name.

Depending on the value of method, this function delegates to the appropriate handler:

• If method equals LOOKUP_FIELDS_METHOD, it calls lookupFields.
• If method equals GET_FIELDS_METHOD, it calls getFields.
• For any other value, it returns a JSON response indicating the method was not found.

Specified by:

handleStepAction in class BaseStepHelper

Parameters:

method - the action method to perform (e.g., lookup fields, get fields)

transMeta - the transformation metadata context

queryParams - additional query parameters for the action

Returns:

a JSONObject containing the result of the action or an error response if the method is not found

See Also:

• BaseStepHelper.handleStepAction(String, TransMeta, Map)