apache-beam

1热度

1回答

我正在处理我们想要监视客户端登录/注销的应用程序。由于ActiveMQ包含咨询主题，可以提醒您新建连接和删除连接，因此建议使用此通知消息（ActiveMQ.Advisory.Connection）。这在开发过程中运行良好，但现在，当我们要在我们的经纪人网络中进行生产时，我们注意到来自网络中远程经纪人的消息没有传到我们的消费者手中。我们的设置是：监制 | 代理A和B（主从）在站点1 - >这些具

0热度

1回答

Qt插件：无法从Qt插件获取枚举的元数据

我可以从我的Qt插件访问大量元数据，但无法像QMetaEnums那样访问枚举。然而，我可以在我的类中获得返回该枚举的方法，并且可以将其转换为QMetaType并获取其ID（1026）。我也需要QMetaEnum中包含的信息。我想我错过了一些东西。请看看我的代码： //Plugin interface class PluginInterface { public: virtual v

0热度

1回答

PubSub的资源设置分配timestampLabel

在修改我的工作从PubSub的读取时开始使用timestampLabel后失败的数据流任务，资源设置似乎打破每次我尝试启动并出现以下错误的工作： (c8bce90672926e26): Workflow failed. Causes: (5743e5d17dd7bfb7): Step setup_resource_/subscriptions/project-name/subscription-n

0热度

1回答

为什么DoFnTester不再支持finishBundle（）中的输出？

我们有一些功能可以批量处理捆绑中的元素。他们需要输出finishBundle（）方法中的最后一批。类似于对this previous question的回答中所述。在最新的基于Beam 0.4.0的Dataflow 2.0.0-beta1版本中，如果被测试的函数调用上下文中的输出方法，则DoFnTester会从其finishBundle（）方法抛出UnsupportedOperationExc

1热度

1回答

Google DataFlow＆Reading Parquet文件

尝试使用Google DataFlow Java SDK，但对于我的用例，我的输入文件是.parquet文件。找不到任何即开即用的功能，将镶木地板作为有界数据源读入DataFlow管道。据我所知，我可以根据Parquet Reader创建一个编码器和/或接收器有点像AvroIO。有没有人可以建议如何实施它的最佳方式？或者指引我参考How-to \ examples？感谢您的帮助！ --a

0热度

1回答

云数据流作业无故失败

我有一个使用Apache Beam API（0.4.0）执行的Google Cloud Dataflow作业。该管道使用本地亚军成功运行。当我使用数据流运行器提交作业时，提交作业，但在32秒后失败，不显示任何原因。日志似乎是空的。的gcloud CLI没有任何帮助，或者： $ gcloud beta dataflow logs list 2017-01-23_12_51_23-546358424

0热度

2回答

挑选并使用数组中的随机类

有没有办法从对象数组中选取一个随机对象？我尝试了几种我能想到但没有用的方法。我想在随机类中使用一个函数（所有类将具有相同的函数但返回不同（但它们都返回一个Image，它们只有不同的路径））。下面是我的一些代码，我有 Car car; Ford ford; Mazda mazda; Fiat fiat; Rover rover; Car

2热度

1回答

'int'对象是不可调用的错误python

嘿家伙，所以我得到这个“TypeError：'int'对象不可调用”错误当我运行此代码时，我做了一些研究，我认为这是与我的变量命名？有人可以向我解释什么是错的？ class account(object): def set(self, bal): self.balance = bal def balance(self): return balance

0热度

1回答

在侧面输出上构建具有相同转换的数据流管道

我们正在构建一个流式管道，其中数据在几个步骤中可能会遇到不同的错误，例如序列化错误，验证错误和写入存储时的运行时错误。无论何时发生错误，我们都会将数据导向侧面输出。错误处理逻辑在这些侧面输出上是相同的。我们将数据写入一个常见的错误存储器中进行后处理/报告。至少有三个选项来构建pipleine。（下面的伪代码）用一个新的变换实例处理每个边输出。 sideOutput1.apply(new Ha

0热度

2回答

gmail api：回复电子邮件已经在vb.net的收件箱

有人与vb.net的gmail工作？如何访问我的收件箱并查找从特定人员发送的电子邮件并将回复发送给他们？我有一份与学校保持联系的人的名单，由于我一段时间没有回复他们，我想将一个电子邮件地址列表添加到程序中，然后从该程序中找到电子邮件这些人，它会回复这些电子邮件