Execution Information Locations

import org.apache.hop.core.gui.plugin.GuiPlugin;
import org.apache.hop.core.gui.plugin.GuiWidgetElement;
import org.apache.hop.execution.Execution;
import org.apache.hop.execution.ExecutionData;
import org.apache.hop.execution.ExecutionInfoLocation;
import org.apache.hop.execution.ExecutionType;
import org.apache.hop.execution.ExecutionState;
import org.apache.hop.execution.IExecutionInfoLocation;
import org.apache.hop.execution.plugin.ExecutionInfoLocationPlugin;
import org.apache.hop.metadata.api.HopMetadataProperty;
import lombok.Getter;
import lombok.Setter;

@ExecutionInfoLocationPlugin(
    id = "CustomElasticLocation",
    name = "Custom Elasticsearch Location",
    description = "Persists Hop execution history and metrics to Elasticsearch"
)
@GuiPlugin
@Getter
@Setter
public class CustomElasticExecutionInfoLocation implements IExecutionInfoLocation {

  @GuiWidgetElement(
      id = "cluster_url",
      type = GuiElementType.TEXT,
      label = "Elasticsearch URL",
      parentId = ExecutionInfoLocation.GUI_PLUGIN_ELEMENT_PARENT_ID
  )
  @HopMetadataProperty(key = "cluster_url")
  private String clusterUrl;

  @Override
  public void initialize(IVariables variables, IHopMetadataProvider metadataProvider)
      throws HopException {
    // Connect to target storage
  }

  // --- Writing telemetry during execution ---

  @Override
  public void registerExecution(Execution execution) throws HopException {
    // Write execution metadata (pipeline/workflow name, start time, parameters)
  }

  @Override
  public void updateExecutionState(ExecutionState executionState) throws HopException {
    // Update runtime metrics (lines read, written, errors, status changes)
  }

  @Override
  public void registerData(ExecutionData executionData) throws HopException {
    // Store sampled row data and execution logs
  }

  // --- Reading telemetry for the Hop GUI and API ---

  @Override
  public Execution getExecution(String executionId) throws HopException {
    return fetchExecutionRecord(executionId);
  }

  @Override
  public ExecutionState getExecutionState(String executionId) throws HopException {
    return fetchExecutionState(executionId);
  }

  @Override
  public List<String> findChildIds(ExecutionType parentType, String parentExecutionId)
      throws HopException {
    // Critical: returns child execution IDs (transforms or sub-workflows) for drill-down
    return queryChildren(parentExecutionId);
  }

  @Override
  public void close() throws HopException {
    // Flush pending buffers and close client connections
  }
}