org.apache.shardingsphere.elasticjob.dataflow.job

接口 DataflowJob<T>

类型参数:

T - type of data

所有超级接口:

org.apache.shardingsphere.elasticjob.api.ElasticJob

public interface DataflowJob<T>
extends org.apache.shardingsphere.elasticjob.api.ElasticJob

Dataflow job.

方法概要

限定符和类型	方法和说明
List<T>	fetchData(org.apache.shardingsphere.elasticjob.api.ShardingContext shardingContext) Fetch to be processed data.
void	processData(org.apache.shardingsphere.elasticjob.api.ShardingContext shardingContext, List<T> data) Process data.

方法详细资料

fetchData

List<T> fetchData(org.apache.shardingsphere.elasticjob.api.ShardingContext shardingContext)

Fetch to be processed data.

参数:

shardingContext - sharding context

返回:

to be processed data

processData

void processData(org.apache.shardingsphere.elasticjob.api.ShardingContext shardingContext,
                 List<T> data)

Process data.

参数:

shardingContext - sharding context

data - to be processed data