]> git.somenet.org - pub/jan/dst18.git/blob - ass3-event/src/main/java/dst/ass3/event/IEventSourceFunction.java
GITOLITE.txt
[pub/jan/dst18.git] / ass3-event / src / main / java / dst / ass3 / event / IEventSourceFunction.java
1 package dst.ass3.event;
2
3 import org.apache.flink.api.common.functions.RichFunction;
4 import org.apache.flink.configuration.Configuration;
5 import org.apache.flink.streaming.api.functions.source.SourceFunction;
6
7 import dst.ass3.event.model.domain.IUploadEventInfo;
8
9 /**
10  * A RichFunction & SourceFunction for IUploadEventInfo objects.
11  */
12 public interface IEventSourceFunction extends RichFunction, SourceFunction<IUploadEventInfo> {
13
14     @Override
15     void open(Configuration parameters) throws Exception;
16
17     @Override
18     void close() throws Exception;
19
20     @Override
21     void run(SourceContext<IUploadEventInfo> ctx) throws Exception;
22
23     @Override
24     void cancel();
25 }