Class DefaultTaskInfo

  • All Implemented Interfaces:
    org.apache.flink.datastream.api.context.TaskInfo

    public class DefaultTaskInfo
    extends Object
    implements org.apache.flink.datastream.api.context.TaskInfo
    Default implementation of TaskInfo.
    • Constructor Detail

      • DefaultTaskInfo

        public DefaultTaskInfo​(int parallelism,
                               int maxParallelism,
                               String taskName)
    • Method Detail

      • getParallelism

        public int getParallelism()
        Specified by:
        getParallelism in interface org.apache.flink.datastream.api.context.TaskInfo
      • getMaxParallelism

        public int getMaxParallelism()
        Specified by:
        getMaxParallelism in interface org.apache.flink.datastream.api.context.TaskInfo
      • getTaskName

        public String getTaskName()
        Specified by:
        getTaskName in interface org.apache.flink.datastream.api.context.TaskInfo