apache-beam

0热度

4回答

我想要xdebug的跟踪功能以.html输出文件，而不是.xt。这是xdebug_start_trace函数的参数： http://grahamwideman.wikispaces.com/PHP+trace+with+XDebug 我测试了它们，但它们不起作用。有没有办法使用xdebug以.html格式输出文件，并避免输入更多的代码？

1热度

3回答

jQuery的回调元素中找到

我曾尝试下面的代码： $('a.buildMenu').click(function (event) { // Prevent normal behaviour event.preventDefault(); // Stops it bubbling to the document event.stopPropagatio

-1热度

2回答

给予超时错误，而在Android模拟器

开工作灯混合的应用程序当我尝试在Android模拟器运行我的工作灯混合的应用程序，它给我超时错误。但是，它在我的android手机上运行良好。帮助我如何在Android模拟器中运行它。顺便说一句，我增加了loadUrlTimeoutValue到60秒。还是它不工作

1热度

1回答

Bigquery：将类转换为Bigquery TableSchema

是否知道将Java类（通过jaxb从xsd生成，因此包含XML绑定注释）转换为BigQuery TableSchema的方法。或者将JsonScheam转换为TableSchema。我必须这样做，大约60个或更少的复杂类。问候

0热度

1回答

DataStoreIO.Write链接另一个转换

我正在使用Apache Beam Java SDK创建Google数据流管道。我在那里进行了一些转换，最后我创建了一个实体集合（PCollection < Entity>）。我需要将它写入Google DataStore，然后在所有实体写入后执行另一次转换。（例如通过PubSub消息将保存的对象的ID广播给多个订阅者）。现在，存储PCollection的方法是：。 entities.Datas

0热度

1回答

在Apache Beam中写入文件

我正在Windows中使用Apache Beam运行WordCount程序，通过DirectRunner.I可以看到在临时文件夹（在src/main/resources /下）创建的输出文件。输出文件失败。下面的代码片段： p.apply("ReadMyFile", TextIO.read().from("src/main/resources/input.txt")) .appl

0热度

1回答

使用状态和定时器处理

使用有状态处理和定时器对Beam Dataflow运行器（从v2.1.0起）有任何准则或限制吗？诸如对状态大小或更新频率等的限制？候选流式管道将广泛使用状态和定时器来实现用户会话状态，并将Bigtable作为持久存储。

1热度

2回答

如何在Apache Beam中序列化运行时创建的类

我有一个apache-beam应用程序，它使用数据流运行器在本地运行直接运行程序和谷歌云。它在本地工作，但失败的谷歌数据流亚军。下面是错误的痕迹：（9938ce94c0752c7）：了java.lang.RuntimeException：com.google.cloud.dataflow.worker.repackaged.com.google.common.util.concurrent.U

1热度

1回答

登录Google云数据流中的Beam应用程序

我有一个Beam应用程序，该应用程序在directrunner本地成功运行，并向我提供我的本地控制台上的代码中的所有日志信息。但是，当我尝试在Google云端数据流环境中运行它时，我只能在本地控制台上看到这些日志信息，但它们没有显示在Google云端控制台上用于数据流作业，无论是在StackDriver日志页面中。这里是我做的，从我的本地控制台运行我的数据流亚军代码： mvn compile e

12热度

1回答

import apache_beam元类冲突

当我尝试导入apache beam时，出现以下错误。 >>> import apache_beam Traceback (most recent call last): File "<stdin>", line 1, in <module> File "/home/toor/pfff/local/lib/python2.7/site-packages/apache_beam/