Class TestingJobInfo
- java.lang.Object
-
- org.apache.flink.connector.testutils.source.TestingJobInfo
-
- All Implemented Interfaces:
org.apache.flink.api.common.JobInfo
public class TestingJobInfo extends Object implements org.apache.flink.api.common.JobInfo
Test implementation forJobInfo.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classTestingJobInfo.BuilderBuilder forTestingJobInfo.
-
Constructor Summary
Constructors Constructor Description TestingJobInfo(org.apache.flink.api.common.JobID jobID, String jobName)
-
-
-
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:
getJobIdin interfaceorg.apache.flink.api.common.JobInfo
-
getJobName
public String getJobName()
- Specified by:
getJobNamein interfaceorg.apache.flink.api.common.JobInfo
-
-