package com.hisun.loganalysis.spark.kafka;

import java.io.Serializable;

import org.apache.spark.api.java.JavaSparkContext;


interface Processor extends Serializable {
	
	void before(JavaSparkContext context);
	
	void after(JavaSparkContext context);
	
	@Deprecated
	Object process(JavaSparkContext context) throws Exception;

	Object processAsAsync(JavaSparkContext context) throws Exception;
}
