Class TestingJobInfo

  • All Implemented Interfaces:
    org.apache.flink.api.common.JobInfo

    public class TestingJobInfo
    extends Object
    implements org.apache.flink.api.common.JobInfo
    Test implementation for JobInfo.
    • Constructor Detail

      • TestingJobInfo

        public TestingJobInfo​(org.apache.flink.api.common.JobID jobID,
                              String jobName)
    • Method Detail

      • getJobId

        public org.apache.flink.api.common.JobID getJobId()
        Specified by:
        getJobId in interface org.apache.flink.api.common.JobInfo
      • getJobName

        public String getJobName()
        Specified by:
        getJobName in interface org.apache.flink.api.common.JobInfo