Class InitContextBase
- java.lang.Object
-
- org.apache.flink.streaming.runtime.operators.sink.InitContextBase
-
- All Implemented Interfaces:
org.apache.flink.api.connector.sink2.InitContext
@Internal public class InitContextBase extends Object implements org.apache.flink.api.connector.sink2.InitContext
Base implementation for theInitContext.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.flink.api.common.JobInfogetJobInfo()OptionalLonggetRestoredCheckpointId()org.apache.flink.api.common.functions.RuntimeContextgetRuntimeContext()org.apache.flink.api.common.TaskInfogetTaskInfo()
-
-
-
Method Detail
-
getRestoredCheckpointId
public OptionalLong getRestoredCheckpointId()
- Specified by:
getRestoredCheckpointIdin interfaceorg.apache.flink.api.connector.sink2.InitContext
-
getJobInfo
public org.apache.flink.api.common.JobInfo getJobInfo()
- Specified by:
getJobInfoin interfaceorg.apache.flink.api.connector.sink2.InitContext
-
getTaskInfo
public org.apache.flink.api.common.TaskInfo getTaskInfo()
- Specified by:
getTaskInfoin interfaceorg.apache.flink.api.connector.sink2.InitContext
-
getRuntimeContext
public org.apache.flink.api.common.functions.RuntimeContext getRuntimeContext()
-
-