package test;

import org.apache.flink.api.java.tuple.Tuple5;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.windowing.RichWindowFunction;
import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
import org.apache.flink.util.Collector;
import org.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class TestWindow extends RichWindowFunction<Tuple5<String, String, String, JSONObject>, Void, String, TimeWindow> {

	private static final long serialVersionUID = 1231260406743880674L;

	private static final Logger logger = LoggerFactory.getLogger(TestWindow.class);


	@Override
	public void open(Configuration parameters) throws Exception {
	}

	@Override
	public void apply(String key, TimeWindow window, Iterable<Tuple5<String, String, String, JSONObject>> values, Collector<Void> out) throws Exception {
	}
}