/**
 * This interface represents a context for a processor or elements of a processor.
 */
public interface RuntimeContext {

...

  /**
   * @return {@link TriggeringScheduleInfo} if the program is triggered by a schedule. Otherwise, returns {@code null}.
   */
  @Nullable
  TriggeringScheduleInfo getTriggeringScheduleInfo();
 
...
 
}

/**
 * The information of a schedule that can be used by the program launched by the schedule.
 */
public class TriggeringScheduleInfo {

  private final String name;
  private final String description;
  private final TriggerInfo triggerInfo;
  private final Map<String, String> properties;

  public TriggeringScheduleInfo(String name, String description, TriggerInfo triggerInfo,
                                Map<String, String> properties) {
    this.name = name;
    this.description = description;
    this.properties = properties;
    this.triggerInfo = triggerInfo;
  }

  /**
   * @return Schedule's name, which is unique in an application.
   */
  public String getName() {
    return name;
  }

  /**
   * @return Description of the schedule.
   */
  public String getDescription() {
    return description;
  }

  /**
   * @return Information of the trigger contained in this schedule.
   */
  public TriggerInfo getTriggerInfo() {
    return triggerInfo;
  }

  /**
   * @return Properties of the schedule.
   */
  public Map<String, String> getProperties() {
    return properties;
  }
}

/**
 * Base class for the trigger information to be passed to the triggered program.
 */
public abstract class TriggerInfo {
  private final Trigger.Type type;

  public TriggerInfo(Trigger.Type type) {
    this.type = type;
  }

  /**
   * @return The type of the trigger.
   */
  public Trigger.Type getType() {
    return type;
  }
}

/**
 * The program status trigger information to be passed to the triggered program.
 */
public class ProgramStatusTriggerInfo extends TriggerInfo {

  private final String namespace;
  private final ApplicationSpecification applicationSpecification;
  private final ProgramType programType;
  private final String program;
  private final Set<ProgramStatus> triggerStatues;
  @Nullable
  private final String runId;
  @Nullable
  private final ProgramStatus programStatus;
  @Nullable
  private final WorkflowToken workflowToken;
  @Nullable
  private final Map<String, String> runtimeArguments;

  public ProgramStatusTriggerInfo(String namespace, ApplicationSpecification applicationSpecification,
                                  ProgramType programType, String program, Set<ProgramStatus> triggerStatues,
                                  @Nullable String runId, @Nullable ProgramStatus programStatus,
                                  @Nullable WorkflowToken workflowToken,
                                  @Nullable Map<String, String> runtimeArguments) {
    super(Trigger.Type.PROGRAM_STATUS);
    this.namespace = namespace;
    this.applicationSpecification = applicationSpecification;
    this.programType = programType;
    this.program = program;
    this.triggerStatues = triggerStatues;
    this.runId = runId;
    this.programStatus = programStatus;
    this.workflowToken = workflowToken;
    this.runtimeArguments = runtimeArguments;
  }

  /**
   * @return The namespace of the triggering program.
   */
  public String getNamespace() {
    return namespace;
  }

  /**
   * @return Schedule's name, which is unique in an application The application specification of the application that contains the triggering program.
   */
  public StringApplicationSpecification getNamegetApplicationSpecification() {
    return nameapplicationSpecification;
  }

  /**
   * @return The Descriptionprogram type of the triggering scheduleprogram.
   */
  public StringProgramType getDescriptiongetProgramType() {
    return descriptionprogramType;
  }

  /**
   * @return The program Informationname of the trigger contained in this scheduletriggering program.
   */
  public TriggerInfoString getTriggerInfogetProgram() {
    return triggerInfoprogram;
  }

  /**
   * @return PropertiesAll of the schedule.program statuses that can */satisfy the program publicstatus Map<String,trigger.
String> getProperties() {   */
 return properties; public Set<ProgramStatus> }
}

/**
 * Base class for the trigger information to be passed to the triggered program.
 */
public abstract class TriggerInfo {
  private final Trigger.Type type;

  public TriggerInfo(Trigger.Type type) {
    this.type = type;
  }

  /**
   * @return The type of the trigger.
   */
  public Trigger.Type getTypegetTriggerStatues() {
    return triggerStatues;
  }

  /**
   * @return The program run Id of the triggering program run that can satisfy the program status trigger,
   *         or {@code null} if there is no such run.
   */
  @Nullable
  public String getRunId() {
    return typerunId;
  }
}

/**
  * The program status trigger information to be passed to the triggered program.
 */
public class ProgramStatusTriggerInfo extends TriggerInfo {

  private final String namespace;
  private final ApplicationSpecification applicationSpecification;
  private final ProgramType programType;
  private final String program;
  private final Set<ProgramStatus> triggerStatues;
  @Nullable
  private final String runId;/**
   * @return The program status of the triggering program run that can satisfy the program status trigger,
   *         or {@code null} if there is no such run.
   */
  @Nullable
  privatepublic final ProgramStatus programStatus;getProgramStatus() {
 @Nullable   private final WorkflowToken workflowTokenreturn programStatus;
  @Nullable}

 private final/**
Map<String, String> runtimeArguments; * @return The publicworkflow ProgramStatusTriggerInfo(String namespace, ApplicationSpecification applicationSpecification,
       token if the program is a workflow with a run that can
   *         satisfy the program status trigger, or an empty workflow token if there's no such ProgramTyperun.
programType, String program, Set<ProgramStatus>* triggerStatues,        Return {@code null} if the program is not a workflow.
   */
  @Nullable
  public WorkflowToken getWorkflowToken() {
    @Nullablereturn StringworkflowToken;
runId, @Nullable ProgramStatus}
programStatus,
  /**
   * @return The runtime arguments of the triggering program run that can satisfy the program status trigger,
   *        @Nullable WorkflowTokenor workflowToken,{@code null} if there is no such run.
   */
  @Nullable
  public Map<String, String> getRuntimeArguments() {
    return runtimeArguments;
  }
}

/**
 * Base @Nullableclass Map<String,for String>identifiers runtimeArguments)of {properties from the triggering  super(Trigger.Type.PROGRAM_STATUS);
    this.namespace = namespace;
    this.applicationSpecification = applicationSpecification;
    this.programType = programType;
    this.program = program;
    this.triggerStatues = triggerStatues;
    this.runId = runId;
    this.programStatus = programStatus;
    this.workflowToken = workflowToken;
    this.runtimeArguments = runtimeArguments;
  }

  /**
   * @return The namespace of the triggering program.
   */
  public String getNamespace() {
    return namespacepipeline.
 */
public abstract class TriggeringPipelinePropertyId {

  /**
   * The type of the triggering pipeline property
   */
  public enum Type {
    RUNTIME_ARG,
    PLUGIN_PROPERTY,
    TOKEN
  }

  private final Type type;
  private final String namespace;
  private final String pipelineName;

  public TriggeringPipelinePropertyId(Type type, String namespace, String pipelineName) {
    this.type = type;
    this.namespace = namespace;
    this.pipelineName = pipelineName;
  }

  /**
   * @return TheType application specification of the applicationtriggering that contains the triggering programpipeline property.
   */
  public ApplicationSpecificationType getApplicationSpecificationgetType() {
    return applicationSpecificationtype;
  }

  /**
   * @return The program typeNamespace of the triggering programpipeline.
   */
  public ProgramTypeString getProgramTypegetNamespace() {
    return programTypenamespace;
  }

  /**
   * @return TheNames program name of the triggering programpipeline.
   */
  public String getProgramgetPipelineName() {
    return programpipelineName;
  }
}

 /**
 * Identifier of /**
   * @return All the program statuses that can satisfy the program status trigger.
   */
  public Set<ProgramStatus> getTriggerStatues() {
    return triggerStatuesruntime arguments from the triggering pipeline.
 */
public class TriggeringPipelineRuntimeArgId extends TriggeringPipelinePropertyId {
  private final String runtimeArgumentKey;

  public TriggeringPipelineRuntimeArgId(String namespace, String pipelineName, String runtimeArgumentKey) {
    super(Type.RUNTIME_ARG, namespace, pipelineName);
    this.runtimeArgumentKey = runtimeArgumentKey;
  }

  /**
   * @return The key programof the runruntime Idargument ofin the triggering pipeline.
program run that can*/
satisfy the programpublic status trigger,
String getRuntimeArgumentKey() {
  *  return runtimeArgumentKey;
  }
}

/**
 or* {@codeIdentifier null}of ifplugin thereproperty isfrom nothe suchtriggering runpipeline.
 
 */
public class @NullableTriggeringPipelinePluginPropertyId extends  public String getRunId() TriggeringPipelinePropertyId {
 private final String return runIdpluginName;
 private }final String propertyKey;
 /**
 public TriggeringPipelinePluginPropertyId(String *namespace, @returnString ThepipelineName,
program statusString ofpluginName, theString triggeringpropertyKey) program{
run that can satisfy the program status trigger,
   *         or {@code null} if there is no such run.
   */
  @Nullable
  public ProgramStatus getProgramStatus() {
    return programStatus;
  }

  /**
  super(Type.PLUGIN_PROPERTY, namespace, pipelineName);
 this.pluginName = pluginName;
 this.propertyKey = propertyKey;
 }

 /**
 * @return The name of the plugin in the triggering pipeline.
 */
 public String getPluginName() {
 return pluginName;
 }

 /**
 * @return The workflow token if the program is a workflow with a run that can
   *         satisfy the program status trigger, or an empty workflow token if there's no such run.
   *         Return {@code null} if the program is not a workflow.
   */
  @Nullable
  public WorkflowToken getWorkflowToken() {
    return workflowTokenkey of the plugin property in the triggering pipeline.
 */
 public String getPropertyKey() {
 return propertyKey;
 }
}

 /**
 * Identifier of token from the triggering pipeline.
 */
public class TriggeringPipelineTokenId extends TriggeringPipelinePropertyId {
  private final String tokenKey;
  private final String nodeName;

  public TriggeringPipelineTokenId(String namespace, String pipelineName, String tokenKey, String nodeName) {
    super(Type.TOKEN, namespace, pipelineName);
    this.tokenKey = tokenKey;
    this.nodeName = nodeName;
  }

  /**
   * @return The runtime arguments of the triggering program run that can satisfy the program status trigger,key of the token in the triggering pipeline.
   */
  public String getTokenKey() {
    return tokenKey;
  }

  /**
   * @return The name of orthe {@codenode null}where ifthe theretoken is generated in nothe suchtriggering runpipeline.
   */
  @Nullable
  public Map<String, String> getRuntimeArgumentsString getNodeName() {
    return runtimeArgumentsnodeName;
  }
}