B G L O S T V

B

buildClient(BlockingQueue<String>, HttpHosts, StreamingEndpoint) - Method in class org.apache.ignite.stream.twitter.TwitterStreamer

G

getAccessToken() - Method in class org.apache.ignite.stream.twitter.OAuthSettings

getAccessTokenSecret() - Method in class org.apache.ignite.stream.twitter.OAuthSettings

getClient(BlockingQueue<String>) - Method in class org.apache.ignite.stream.twitter.TwitterStreamer

getConsumerKey() - Method in class org.apache.ignite.stream.twitter.OAuthSettings

getConsumerSecret() - Method in class org.apache.ignite.stream.twitter.OAuthSettings

L

log - Variable in class org.apache.ignite.stream.twitter.TwitterStreamer

Logger.

O

OAuthSettings - Class in org.apache.ignite.stream.twitter

OAuth keys holder.

OAuthSettings(String, String, String, String) - Constructor for class org.apache.ignite.stream.twitter.OAuthSettings

org.apache.ignite.stream.twitter - package org.apache.ignite.stream.twitter

Contains implementation of Twitter Streamer.

S

setApiParams(Map<String, String>) - Method in class org.apache.ignite.stream.twitter.TwitterStreamer

Sets API Params.

setBufferCapacity(Integer) - Method in class org.apache.ignite.stream.twitter.TwitterStreamer

Sets Buffer capacity.

setEndpointUrl(String) - Method in class org.apache.ignite.stream.twitter.TwitterStreamer

Sets Endpoint URL.

setThreadsCount(int) - Method in class org.apache.ignite.stream.twitter.TwitterStreamer

Sets Threads count.

start() - Method in class org.apache.ignite.stream.twitter.TwitterStreamer

Starts streamer.

stop() - Method in class org.apache.ignite.stream.twitter.TwitterStreamer

Stops streamer.

T

TwitterStreamer<K,V> - Class in org.apache.ignite.stream.twitter

Streamer that consumes from a Twitter Streaming API and feeds transformed key-value pairs, by default , into an IgniteDataStreamer instance.

TwitterStreamer(OAuthSettings) - Constructor for class org.apache.ignite.stream.twitter.TwitterStreamer

V

validateConfig() - Method in class org.apache.ignite.stream.twitter.TwitterStreamer

Validates config at start.

B G L O S T V