new TwitterUtils()
Methods
(static) createStream(jssc, twitterAuth, filters) → {ReceiverInputDStream}
Create a input stream that returns tweets received from Twitter.
Storage level of the data will be the default StorageLevel.MEMORY_AND_DISK_SER_2.
Parameters:
Name | Type | Description |
---|---|---|
jssc |
module:eclairjs/streaming.StreamingContext | JavaStreamingContext object |
twitterAuth |
module:eclairjs/streaming/twitter.TwitterAuthorization | Twitter Authorization |
filters |
Array.<string> | Set of filter strings to get only those tweets that match them |
Returns:
- Type
- ReceiverInputDStream