基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 2 元　

支付宝支付

微信支付

   源码介绍

---

package com.paascloud.elastic.demo;

import com.google.common.collect.Lists;
import com.paascloud.elastic.lite.JobParameter;
import com.paascloud.elastic.lite.annotation.ElasticJobConfig;
import com.paascloud.elastic.lite.job.AbstractBaseDataflowJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * The class Dataflow job demo.
 *
 * @author paascloud.net @gmail.com
 */
@ElasticJobConfig(cron = "0/50 * * * * ? ", listener = DataflowJobDemoListener.class, jobParameter = "fetchNum=200,taskType=SENDING_MESSAGE")
@Component
@Slf4j
public class DataflowJobDemo extends AbstractBaseDataflowJob<Foo> {
	private List<Foo> list = Lists.newArrayList(new Foo(1L), new Foo(2L));

	@Override
	protected List<Foo> fetchJobData(final JobParameter jobTaskParameter) {
		log.info("fetchJobData - jobTaskParameter={}", jobTaskParameter);
		return list;
	}

	@Override
	protected void processJobData(final List<Foo> taskList) {
		log.info("processJobData - taskList={}", taskList);
		list.clear();
	}
}