package com.yoho.kisjob.demo;

import java.util.Iterator;

import lombok.extern.slf4j.Slf4j;

import org.springframework.stereotype.Service;

import com.yoho.kisjob.common.meta.Writable;
import com.yoho.kisjob.jobnode.elastic.Executor;

@Service
@Slf4j
public class TestExecutor implements Executor {

	@Override
	public void execute(String key, Iterator<Writable> values) {
		log.debug("Begin to do executor.");

		while (values.hasNext()) {
			Writable v = values.next();
			log.debug("Execute record with key: " + key + ", value= " + v);
			try {
				Thread.sleep(1000L);
			} catch (InterruptedException e) {
				e.printStackTrace();
				Thread.currentThread().interrupt();
			}
		}

		log.debug("End to do executor.");
	}

}