I have problem regarding Apache Flink. I want to have an abstract class that consumes a stream. However the pattern applied to this stream should be interchangeable. TEventType marks the type of the event that is generated from the pattern. Every pattern must implement an interface called IEventPattern The abstract class has a method called applyPatternSelectToStream() The flink compiler always
Tag: streaming
Simple (Twitter + Streaming API + Java + OAuth) example
In my quest to create a simple Java program to extract tweets from Twitter’s streaming API, I have modified this (http://cotdp.com/dl/TwitterConsumer.java) code snippet to work with the OAuth method. The result is the below code, which when executed, throws a Connection Refused Exception. I am aware of Twitter4J however I want to create a program that relies least on other