com.supermap.services.components.impl

类 DefaultJobRunner

  • java.lang.Object
    • com.supermap.services.components.impl.DefaultJobRunner
    • 构造器详细资料

      • DefaultJobRunner

        public DefaultJobRunner()
        
    • 方法详细资料

      • init

        public void init(JobBuildConfig pConfig,
                JobState pState,
                JobDataDeploy dataDeploy)
        
        从接口复制的说明: JobRunner
        对Runner进行初始化
        指定者:
        init 在接口中 JobRunner
        pState - 可以为null
      • start

        public void start()
        
        从接口复制的说明: JobRunner

        开始任务。

        指定者:
        start 在接口中 JobRunner
      • caculateTileScaleInfo

        protected TileScaleInfo caculateTileScaleInfo(ScaleBuildConfig scaleConfig,
                                          Geometry[] regions)
        
      • addWorker

        public void addWorker(TileWorkerClient worker)
        

        添加切图节点。

        参数:
        worker -
        从以下版本开始:
        8.1.1
      • stop

        public void stop()
        
        从接口复制的说明: JobRunner

        停止任务。

        指定者:
        stop 在接口中 JobRunner
      • getState

        public JobState getState()
        
        从接口复制的说明: JobRunner
        获取Job状态。 返回的状态并不是实时的,但是是有效的。 Job执行的过程中,Job的状态可能会被并发的被修改。 当调用这个方法的时候,如果有其它线程正在修改Job的状态,即修改Job所属JobState对象的字段, 这个方法不会与修改的线程同步,所以它返回的状态不是实时的。 但是返回的状态肯定是某次修改完成后的状态,而不是并发修改中的状态(修改中的状态可能是无效非法的),所以返回的状态是有效的。
        指定者:
        getState 在接口中 JobRunner
        返回:
      • setTileCountPerTask

        public void setTileCountPerTask(long value)
        
        从接口复制的说明: JobRunner

        设置每个单元切图任务分配的瓦片数。关于单元切图任务,请参见 TileTask.

        指定者:
        setTileCountPerTask 在接口中 JobRunner
        参数:
        value - 瓦片数。
      • notifyJobDeployCompleted

        public void notifyJobDeployCompleted(java.lang.String workerId)
        
        从接口复制的说明: JobRunner

        通知切图主节点,切图作业在切图节点部署完毕

        指定者:
        notifyJobDeployCompleted 在接口中 JobRunner
      • notifyTaskCompleted

        public void notifyTaskCompleted(java.lang.String taskId,
                               java.lang.String workerId)
        
        从接口复制的说明: JobRunner

        通知切图主节点,某个单元切图任务完成。

        指定者:
        notifyTaskCompleted 在接口中 JobRunner
        参数:
        taskId - 已完成的单元切图任务ID。
        workerId - taskId单元切图任务所在的Woker。
      • notifyTaskCompleted

        public void notifyTaskCompleted(java.lang.String taskId,
                               java.lang.String workerId,
                               TileTaskBuildResult result)
        
        从接口复制的说明: JobRunner

        通知切图主节点,某个单元切图任务完成。

        指定者:
        notifyTaskCompleted 在接口中 JobRunner
      • notifyTaskFailed

        public void notifyTaskFailed(java.lang.String taskid,
                            java.lang.String workerId)
        
        从接口复制的说明: JobRunner

        通知切图主节点,某个单元切图任务失败。

        指定者:
        notifyTaskFailed 在接口中 JobRunner
      • notifyWorkerDisconnected

        public void notifyWorkerDisconnected(java.lang.String workerId)
        
        从接口复制的说明: JobRunner

        通知切图主节点,某个子节点连接失败。

        指定者:
        notifyWorkerDisconnected 在接口中 JobRunner
      • getRemoteWorkspacePath

        public java.lang.String getRemoteWorkspacePath(JobBuildConfig jobBuildConfig)
        

        获取子节点工作空间路径。

        参数:
        jobBuildConfig -
        返回:
        从以下版本开始:
        8.1.1
      • getJobConfig

        public JobBuildConfig getJobConfig()
        
        从接口复制的说明: JobRunner

        获取任务配置信息。

        指定者:
        getJobConfig 在接口中 JobRunner
        返回:
      • updateJobConfig

        public void updateJobConfig(JobBuildConfig config)
        
        从接口复制的说明: JobRunner
        更新任务配置
        指定者:
        updateJobConfig 在接口中 JobRunner
      • dispose

        public void dispose()
        
        从接口复制的说明: Disposable

        释放资源对象。

        指定者:
        dispose 在接口中 Disposable
      • updateBlankRegions

        public void updateBlankRegions(double scale,
                              java.lang.String[] invalidRegionIds,
                              java.lang.String[] validRegionIds,
                              java.lang.String[] noneMarkedRegionIds,
                              boolean markAllInvalid,
                              boolean markAllValid)
        
        从接口复制的说明: JobRunner

        更新白图范围。

        指定者:
        updateBlankRegions 在接口中 JobRunner
      • setDeployTaskThreadCount

        public void setDeployTaskThreadCount(int deployTaskThreadCount)