我正在使用hbc工具构建一个使用流式Api的应用程序。我只想在没有任何trackword或其他过滤器的情况下获得公共流媒体流。我怎样才能做到这一点?以下是我写的代码示例:
StatusesFilterEndpoint endpoint = new StatusesFilterEndpoint();
endpoint.trackTerms(Lists.newArrayList("#aTweet"));
Authentication auth = new OAuth1(consumerKey, consumerSecret, token, secret);
Client client = new ClientBuilder()
.hosts(Constants.STREAM_HOST)
.endpoint(endpoint)
.authentication(auth)
.processor(new StringDelimitedProcessor(queue))
.build();
// Establish a connection
client.connect();
有了这个,我只能追踪一条推特,但不能追踪推特的所有公开流。感谢您的回答^^
StatusesFilterEndpoint使用过滤器端点,它只返回匹配的tweet。hbc核心中还有StatusSampleEndpoint实现,它从所有推文中返回小的随机样本。