Following are the key points described later in this article:
Following are key steps required to be taken to retrieve users tweets:
Pay attention to some of the following facts:
public class FilterStreamExample {
public static final String CONSUMER_KEY = "Your_consumer_key";
public static final String CONSUMER_SECRET = "Your_consumer_secret";
public static final String ACCESS_TOKEN = "Your_access_token";
public static final String ACCESS_TOKEN_SECRET = "Your_access_token_secret";
public static void process(String consumerKey, String consumerSecret,
String token, String secret) throws InterruptedException {
//
// Create queue which would be used to get message
//
BlockingQueue queue = new LinkedBlockingQueue(10000);
//
// Create an endpoint of type StatusesFilterEndpoint; It has APIs to retrieve
// users tweets or treats related with mention or hashtags
//
StatusesFilterEndpoint endpoint = new StatusesFilterEndpoint();
//
// Add one or more users to follow the tweets;
//
endpoint.followings(Lists.newArrayList( 136976940L));
//
// Create OAuth object using consumer keys/secret and access token/secret
//
Authentication auth = new OAuth1(consumerKey, consumerSecret, token,
secret);
//
// Create a new BasicClient. By default gzip is enabled.
//
Client client = new ClientBuilder().hosts(Constants.STREAM_HOST)
.endpoint(endpoint).authentication(auth)
.processor(new StringDelimitedProcessor(queue)).build();
//
// Establish a connection
//
client.connect();
//
// Code below would extract message as it appears on Twitter
// Do whatever needs to be done with messages; In the code below,
// the message is printed; In real world, the message could be stored
// in Hadoop storage
//
for (int msgRead = 0; msgRead < 1000; msgRead++) {
String msg = queue.take();
System.out.println(msg);
}
client.stop();
}
public static void main(String[] args) {
try {
FilterStreamExample.process(CONSUMER_KEY, CONSUMER_SECRET,
ACCESS_TOKEN, ACCESS_TOKEN_SECRET);
} catch (InterruptedException e) {
System.out.println(e);
}
}
}
Last updated: 28th Aug, 2024 Confusion among data scientists regarding ROC Curve and AUC often…
Last updated: 27th Aug, 2024 Classification models are used in classification problems to predict the…
Last updated: 26th August, 2024 In this blog post, we will discuss the concepts of…
Last updated: 25th August, 2024 In machine learning, model complexity and overfitting are related in…
Last updated: 24th August, 2024 Model parallelism and data parallelism are two strategies used to…
Last updated: 24th August, 2024 The performance of the machine learning models on unseen datasets…