问题标签 [twitter-util]

如何创建 Function1 对象以在 Java 中 finagle 的 Future 对象的 flatMap 方法中使用？

试过这个：

但它不起作用：

错误:(22, 73) java: is not abstract and does not override abstract method andThen$mcVJ$sp(scala.Function1) in scala.Function1

我正在使用最新的 Spark master，此外，我正在加载这些 jars： - spark-streaming-twitter_2.10-1.1.0-SNAPSHOT.jar - twitter4j-core-4.0.2.jar - twitter4j-stream-4.0.2 。罐

我在 shell 中执行的简单测试程序如下所示：

但是，我不会收到任何推文。我看到的主要错误是

然后对于每次迭代：

我不确定问题出在哪里。如何验证我的 Twitter 凭据是否被正确识别？可能还有另一个罐子不见了？

我在解析 android 库时遇到了一点问题。查询结果中缺少用户的认证数据。因此 ParseTwitterUtils 无法判断用户是否已链接。

有没有办法在使用 TwitterUtils.createStream() 时只提取发布推文的特定用户？（JAVA）“过滤器”参数指定需要包含在推文中的字符串，但我不确定如何使用它来指定我感兴趣的用户。我有这个 ：

这给了我包含“#USA”的推文我需要的是一种倾听特定用户并查看他发布的内容的方法。

谢谢

我遇到了与 Scala generics 和 boxing的 Java 互操作性问题相同的问题，但我认为那里的解决方案对我不起作用，因为它需要修改第三方代码。

具体来说，从 Java（比如 MyJavaClass）我试图扩展一个本身扩展com.twitter.app.App的 Scala 类（MyScalaClass） 。App 扩展了 com.twitter.util.CloseAwaitable，而这又扩展了 com.twitter.util.Awaitable。

说了这么多，当我终于通过编写 MyJavaClass 来扩展 MyScalaClass 时，我明白了

[错误] MyJavaClass.java:[11,8] MyJavaClass 不是抽象的，并且不会覆盖 com.twitter.util.Awaitable 中的抽象方法 result(com.twitter.util.Duration,com.twitter.util.Awaitable.CanAwait)

我想我只是出于某种原因必须实现result，所以我在 MyJavaClass 中实现了：

现在我明白了

[错误] 返回类型 void 与 scala.runtime.BoxedUnit 不兼容

将我的方法更改为

结果是

[错误] 返回类型 scala.runtime.BoxedUnit 与 void 不兼容

到底是什么......所以我开始用谷歌搜索。Java interoperability woes with Scala generics and boxing的答案似乎是说 Scala 在我的情况下生成与 Java 不兼容的字节码，如果我可以控制一些 Twitter 类（我认为CloseAwaitably）来泛化，我可以解决这个问题它与原始方法实现一起[U <: Unit]并return ().asInstanceOf[U]在原始方法实现中欺骗 scalac 承认“某些不完全单位类型”的可能性（尽管我并不完全清楚它是如何工作的）。

我无法控制 Twitter 类，只有 MyScalaClass 和 MyJavaClass。我实际上并不关心 result 方法——我只想能够从 MyJavaClass 扩展 MyScalaClass，实现我在 MyScalaClass 中定义的一些抽象方法。对于它的价值，我正在使用 Scala 2.10.4、JDK 1.8 和 (twitter) util-core_2.10 6.22.0，如果这是相关的：我真的不知道为什么它需要我result在第一名。从 MyScalaClass 继承的 Scala 类不必实现该方法，并且构建得很好。

我怎样才能解决这个问题？感谢参与。

我知道 Scala Future 变得更好的很多原因。有什么理由改用 Twitter Future 吗？除了 Finagle 使用它的事实。

通过 Future.map/Future.flatMap 保持其值的类 ThreadLocal 类对于跟踪请求非常有用，例如，用于日志记录。

Scala 库中是否存在作为此类 Local 的抽象？

有没有办法将这样的 Local 附加到 ExecutionContext.global？

我正在尝试动态地解释作为字符串给出的代码。例如：

我正在寻找一种可以从中返回真正功能的方法：例如：

将打印 4

用例：我想稍后在我的代码中使用该解释代码中的一些简单函数。例如，他们可以提供类似 def fun(x: Int): Int = x + 1 作为字符串，然后我使用解释器编译/执行该代码，然后我希望能够使用这个 fun(x ) 例如在地图中。

问题是该函数类型对我来说是未知的，这是一个大问题，因为我需要从 IMain 回退。我读过关于反射、类型系统等的文章，经过一番谷歌搜索后，我达到了这一点。我还检查了 twitter 的 util-eval，但我从文档和他们测试中的示例中看不到太多，这几乎是一回事。

如果我知道类型，我可以做类似的事情

它可以正常工作并打印 3 但我被上面所说的问题阻止了，我不知道函数的类型，而这个示例之所以有效，是因为我在定义字符串函数时使用了我使用的类型来测试 IMain作品。

您知道我如何实现此功能的任何方法吗？

我是新手，如有错误请见谅。

谢谢

像下面这样实现的未来是否会获得一个新线程？显然不是（见下面的输出）。为什么？如果我希望我的代码在新线程上运行，我应该怎么做？

输出：

(main,Thread[run-main-0,5,run-main-group-0])

(BeforeTest,Thread[run-main-0,5,run-main-group-0])

(AfterTest,Thread[run-main-0,5,run-main-group-0])

成功的未来

(main123,Thread[run-main-0,5,run-main-group-0])

I have a sequence of functions that return a future. I want to execute them sequentially i.e. after the first function future is complete, execute the next function and so on. Is there a way to do it?

ops: Seq[() => Future[Unit]]