package de.hdm.wim;

import de.hdm.wim.cep.events.MessageEvent;
import de.hdm.wim.cep.events.TokenEvent;
import de.hdm.wim.cep.patterns.RelationToDatePattern;
import de.hdm.wim.cep.source.MessageEventSource;
import de.hdm.wim.cep.source.TokenSource;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * Created by Ben on 16.01.2017.
 */
public class CEPSpeechTokens {

        /**
         * The entry point of application.
         *
         * @param args the input arguments
         * @throws Exception the exception
         */
        public static void main(String[] args) throws Exception {

            final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment();
            env.setParallelism(1); // set Parallelism to 1 Task, to get chat order right

            MessageEventSource evtSrc = new MessageEventSource();
            TokenSource tknSrc = new TokenSource();

            // create a DataStream of MessageEvent from our source
            DataStream<MessageEvent> messageStream = env
                    .addSource(evtSrc);

            // create a DataStream of String from our tokenSource
            DataStream<TokenEvent> tokenStream = env
                    .addSource(tknSrc);

            // run the test pattern
//            TestPattern testPattern = new TestPattern();
//            testPattern.run(env,messageStream);

            // run the sender pattern
//            SenderPattern senderPattern = new SenderPattern();
//            senderPattern.run(env,messageStream);

            // run the relation to date pattern
            RelationToDatePattern relationToDatePattern = new RelationToDatePattern();
            relationToDatePattern.run(env, tokenStream);

            // print message stream
            //messageStream.print();
            tokenStream.print();


            env.execute("CEP chat stream job");
        }
}
package de.hdm.wim;

import de.hdm.wim.cep.events.MessageEvent;
import de.hdm.wim.cep.events.TokenEvent;
import de.hdm.wim.cep.patterns.RelationToDatePattern;
import de.hdm.wim.cep.source.MessageEventSource;
import de.hdm.wim.cep.source.TokenSource;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * Created by Ben on 16.01.2017.
 */
public class CEPSpeechTokens {

        /**
         * The entry point of application.
         *
         * @param args the input arguments
         * @throws Exception the exception
         */
        public static void main(String[] args) throws Exception {

            final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment();
            env.setParallelism(1); // set Parallelism to 1 Task, to get chat order right

            MessageEventSource evtSrc = new MessageEventSource();
            TokenSource tknSrc = new TokenSource();

            // create a DataStream of MessageEvent from our source
            DataStream<MessageEvent> messageStream = env
                    .addSource(evtSrc);

            // create a DataStream of String from our tokenSource
            DataStream<TokenEvent> tokenStream = env
                    .addSource(tknSrc);

            // run the test pattern
//            TestPattern testPattern = new TestPattern();
//            testPattern.run(env,messageStream);

            // run the sender pattern
//            SenderPattern senderPattern = new SenderPattern();
//            senderPattern.run(env,messageStream);

            // run the relation to date pattern
            RelationToDatePattern relationToDatePattern = new RelationToDatePattern();
            relationToDatePattern.run(env, tokenStream);

            // print message stream
            //messageStream.print();
            tokenStream.print();

            env.execute("CEP chat stream job");
        }
}
tidy up