job..period.time.ms
job..cron
job_type :
BSH, 编译且执行beanshell 脚本
JAVA, 编译且执行java脚本
SQL, 编译且执行sql脚本
requires_registration: 0、1;
job_expression:
对应的script
default_schedule:
规则参数设定,job.jobname.period.time.ms or job.jobname.cron
default_auto_start: 0、1;
node_group_id:ALL、目标组ID
任务的频率可以在参数表或者节点属性文件中配置。
当在参数表中管理的时候,它的频率可以在MASTER节点被改变且当同步到其他节点的时候,任务管理器
会以新的频率设定重启任务。
SYMMETRICDS 使用spring的CRON,一些任务对于单节点不能并行运行。他们会锁表来排除其他信号量。
This table is only used if the cluster.lock.enabled is set to true.
route job–创建outgoing batches.
任务处理 channel,每次处理一个,读取到max data to route,每次路由最大行数,读取到还没有被路由的data行
数据行会基于batch algorithm 被委任给outgoing batches。值得注意的是,默认的事物处理算法 在channel中
限制的最大路由数可能会超出依据事务的限制。
一个outgoing batch 创建状态为RT, 数据通过插入到data event中来委托给batch,当batch完成,提交后,状态变更为NE
route job 会依照channel中定义的max batch size-进行一次batch的数据事件的最大数目
如果在一次数据库事务结束前达到了最大的数据事件,并且batch algorithm 设置成了其他的而不是nontransactional,那么这样
batch 就会超出最大数目设置。
route job 委托一个路由来决定哪些节点需要接收数据。
data gaps 跟踪哪些数据还没有被处理。