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 ab…
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 …