Class 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 the InitContext.
    • Method Detail

      • getRestoredCheckpointId

        public OptionalLong getRestoredCheckpointId()
        Specified by:
        getRestoredCheckpointId in interface org.apache.flink.api.connector.sink2.InitContext
      • getJobInfo

        public org.apache.flink.api.common.JobInfo getJobInfo()
        Specified by:
        getJobInfo in interface org.apache.flink.api.connector.sink2.InitContext
      • getTaskInfo

        public org.apache.flink.api.common.TaskInfo getTaskInfo()
        Specified by:
        getTaskInfo in interface org.apache.flink.api.connector.sink2.InitContext
      • getRuntimeContext

        public org.apache.flink.api.common.functions.RuntimeContext getRuntimeContext()