You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ex...@apache.org on 2022/12/30 03:44:48 UTC
[nifi] branch main updated: NIFI-11012 Updated Twitter SDK from 1.1.4 to 2.0.3
This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 09463b0ae5 NIFI-11012 Updated Twitter SDK from 1.1.4 to 2.0.3
09463b0ae5 is described below
commit 09463b0ae5fafaed5b248971839e21296c05e9c8
Author: Pierre Villard <pi...@gmail.com>
AuthorDate: Sat Dec 24 20:40:29 2022 +0100
NIFI-11012 Updated Twitter SDK from 1.1.4 to 2.0.3
This closes #6811
Signed-off-by: David Handermann <ex...@apache.org>
---
.../nifi-twitter-processors/pom.xml | 2 +-
.../processors/twitter/TweetStreamService.java | 28 +++++++++++++++++-----
2 files changed, 23 insertions(+), 7 deletions(-)
diff --git a/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/pom.xml b/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/pom.xml
index 801a520312..757bbfb1df 100644
--- a/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/pom.xml
+++ b/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/pom.xml
@@ -38,7 +38,7 @@
<dependency>
<groupId>com.twitter</groupId>
<artifactId>twitter-api-java-sdk</artifactId>
- <version>1.1.4</version>
+ <version>2.0.3</version>
<exclusions>
<exclusion>
<groupId>org.apache.oltu.oauth2</groupId>
diff --git a/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/TweetStreamService.java b/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/TweetStreamService.java
index f304614e71..027839b5c7 100644
--- a/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/TweetStreamService.java
+++ b/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/TweetStreamService.java
@@ -97,12 +97,12 @@ public class TweetStreamService {
ApiClient client = new ApiClient();
final int connectTimeout = context.getProperty(ConsumeTwitter.CONNECT_TIMEOUT).asTimePeriod(TimeUnit.MILLISECONDS).intValue();
final int readTimeout = context.getProperty(ConsumeTwitter.READ_TIMEOUT).asTimePeriod(TimeUnit.MILLISECONDS).intValue();
- client = client.setConnectTimeout(connectTimeout);
- client = client.setReadTimeout(readTimeout);
+ final TwitterCredentialsBearer bearer = new TwitterCredentialsBearer(context.getProperty(ConsumeTwitter.BEARER_TOKEN).getValue());
+ client.setConnectTimeout(connectTimeout);
+ client.setReadTimeout(readTimeout);
+ client.setTwitterCredentials(bearer);
api = new TwitterApi(client);
- final TwitterCredentialsBearer bearer = new TwitterCredentialsBearer(context.getProperty(ConsumeTwitter.BEARER_TOKEN).getValue());
- api.setTwitterCredentials(bearer);
final String basePath = context.getProperty(ConsumeTwitter.BASE_PATH).getValue();
api.getApiClient().setBasePath(basePath);
@@ -174,9 +174,25 @@ public class TweetStreamService {
public void run() {
try {
if (endpoint.equals(StreamEndpoint.SAMPLE_ENDPOINT)) {
- stream = api.tweets().sampleStream(expansions, tweetFields, userFields, mediaFields, placeFields, pollFields, backfillMinutes);
+ stream = api.tweets().sampleStream()
+ .expansions(expansions)
+ .tweetFields(tweetFields)
+ .userFields(userFields)
+ .mediaFields(mediaFields)
+ .placeFields(placeFields)
+ .pollFields(pollFields)
+ .backfillMinutes(backfillMinutes)
+ .execute();
} else {
- stream = api.tweets().searchStream(expansions, tweetFields, userFields, mediaFields, placeFields, pollFields, backfillMinutes);
+ stream = api.tweets().searchStream()
+ .expansions(expansions)
+ .tweetFields(tweetFields)
+ .userFields(userFields)
+ .mediaFields(mediaFields)
+ .placeFields(placeFields)
+ .pollFields(pollFields)
+ .backfillMinutes(backfillMinutes)
+ .execute();
}
executorService.execute(new TweetStreamHandler());
} catch (final ApiException e) {