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 }