我尝试编写一个封装在PTransform中的自定义波束源。当尝试在本地进行单元测试时，我在运行时得到以下错误： java.lang.IllegalStateException: No translator known for my.new.PTransformorg.apache.beam.runners.direct.RootProviderRegistry.getInitialInputs(RootProviderRegistry.java:69) 我没有在guide或PTransform有没有人知道
浏览 14提问于2020-11-30得票数 0
当我们的管道运行时，这些警告意味着什么？1497年主警告com.google.cloud.dataflow.sdk.Pipeline - Transform AsIterable2没有一个稳定的唯一名称.在未来，这个
将防止重新加载流管道。
浏览 4提问于2015-04-21得票数 0
1回答
文档清楚地指出，我应该使用Source和Sink，但是我看到很多人直接使用与PInput或PDone关联的PInput。源/接收器API是实验性的(它用PTransform解释了所有示例)，但似乎更容易将其与自定义运行程序(例如:星星之火)集成。源/Sink API应该重建PTranform API吗？
我是不是错过了什么东西，清楚地区分了这两种方法？Source/
浏览 4提问于2016-01-11得票数 12
回答已采纳
1回答
我们的最后一个转换是JdbcIO，使用org.neo4j.jdbc.Driver向Neo4j写入
我们目前面临的问题是，当我们运行管道时，它
浏览 1提问于2017-06-23得票数 10
回答已采纳
我意识到，在使用ReadFromDatastore PTransform时，如果查询有一个限制集，则查询不会被拆分到各个工作人员之间。Python类的文档如下：
“.当query配置为limit .时，所有返回的结果都将由单个工作人员读取，以确保数据正确。由于数据是从单个工作人员读取的，这可能会对作业的性能产生重大影响。”在我的例子中，我需要指定限制，因为在Datastore中有更多匹配查询的实体，而不是这个工作所需要</em
浏览 2提问于2017-10-23得票数 0
1回答
我希望在我的媒体基础应用程序中使用。我正在使用'SourceReader‘来读取视频文件。谁能告诉我在哪里以及如何将DMO与MF集成以获得帧率转换。我似乎不知道应该将哪种类型的样本(压缩/未压缩)提供给DMO以获得新的帧率。DMO如何更改帧速率？它会给新的样本一个新的时间戳吗？没有代码示例来演示它的用法。请帮帮忙，我卡住了。
谢谢，Mots
浏览 7提问于2011-12-07得票数 4
我的几个PCollections (来自不同的来源)必须以相同的方式解码。因为我之前给了它们的名称。我天真地尝试过： | 'Decode')
但我的管道建不了。(TypeError:期望有一个PTransform对象，获得Parse)。我认为可以作为管道模块的文档说明：“如果需要应用相同的转换实例，那么应该使用正确<e
浏览 1提问于2018-10-26得票数 3
回答已采纳
有没有办法检查PCollection是否为空？
在Dataflow和Apache的文档中，我没有发现任何相关的内容。
浏览 5提问于2017-10-11得票数 1
回答已采纳
2回答
端点的设计不是在请求时立即返回数据，而是报告ID。然后，客户端应该使用ID检查报表的状态。但是，它似乎不是这样工作的，在异常引发后，程序立即终止，而不需要等待或重试。from apache_beam.utils.retry import with_exponential_ba
浏览 5提问于2022-02-22得票数 1
1回答
是否可以为自定义属性指定这样的要求？ 假设有一个属性类CommandAttribute，它将指定命令的名称。它应该只出现在实现ICommand的类中，这样我们就可以保证像ExecuteCommand(...)这样的方法存在于类中。当然，我可以使用反射来检查应用的类是否在运行时实现了接口，但理想情况下，我们可以在编译时强制执行这一点。
浏览 19提问于2019-05-19得票数 0
回答已采纳
通常使用UITableView时，节的数量和每节的行数都是已知的。但如果他们不是呢？我想实现一个惰性搜索，以便在需要显示新数据时实际搜索下一个匹配项。行中的内容：db.prepareSearch(query)，然后在需要显示新单元格时调用db.nextSearchResult()之类的内容。搜索结果确定是否需要新的部分(搜索结果本质上是排序<em
浏览 1提问于2010-09-16得票数 1
回答已采纳
1回答
是否有任何标准方法来指定vim用于枚举行的一组字符？例如，我是否可以使用小写字母{a，b，.，aa，ab，ac，.}(甚至更好的是，只使用键盘的主行中的字符)，并且仍然使用这个新的引用系统的特定行？我想可能需要一个逃逸钥匙--也许':‘或'g’--但即便如此，如果有人对我如何实现这一点有建议，我会非常感激的。
谢谢。
浏览 4提问于2013-12-06得票数 0
回答已采纳
我正在考虑使用javax.annotaiton.Nonnull中提供的javax.annotaiton.Nonnull注释，该注释将保留策略作为运行时。我希望将注释放在接口上，这样以后的实现就不会中断现有代码，如下所示 @Nonnull public List<A> func();现在我不明白的是，我是否也应该在实现上使用相同的注释。因此，下列哪一项将是编写此接口实现的</em
浏览 2提问于2014-12-24得票数 5
回答已采纳
1回答
我正在使用Google Cloud平台上的AI平台Jupyter Notebook环境(用于Python3的Apache Beam2.28.0)开发Apache Beam管道。from apache_beam.transforms.ptransform import PTransformfrom google.oauth2as beam
from apache_beam.transforms.ptransform import P
浏览 3提问于2021-03-04得票数 1
我正在使用webapplicationbuilder类来创建一个新的web应用程序，并找到了许多文章来帮助实现这一点，但是似乎没有一篇文章指定如何指定URL或应用程序，我只得到了"sharepoint- 123“，其中123是指定的端口，"servername/:123”作为url，而我需要"“。
浏览 0提问于2009-11-02得票数 0
回答已采纳
4回答
最近我发现了一个新的非常有用的命令。它是：或或者只是在麦克身上。
默认情况下，它在指定的程序中打开文件或目录。但是，如果我需要在已经运行的编校器中打开一个文件(我的意思是以某种方式将文件发送给正在运行的进程)，我没有解决方案。我想知道是否有任何方法来实现这一点，或者是否有可能编写一个脚本来实现</em
浏览 0提问于2011-04-23得票数 3
回答已采纳
GcsPath.fromComponents(bucket, object); }));
可以使用哪个PTransform开始读取/处理uris PCollection中的每个文件
浏览 17提问于2017-08-16得票数 2
回答已采纳
1回答
我有一个典型的web应用程序，非常基于CRUD。当某些表或列发生变化时，我们需要存储有关它的历史信息。例如，这可以是包含新/旧列值、时间戳、它所涉及的表、更改它的用户的名称等的审核表。通常，我已经实现了这一点，例如，使用触发器来获取此信息并存储到一个审计表中。
但是，使用SQL Server 2016审核功能是否可以自动实现这一目标？我想到了几个问题: 1)它是否
浏览 2提问于2016-10-05得票数 0
1回答
我正在努力在Sybase中划分一个巨大的表。用例是，该表多年来一直在增长，应用程序不需要超过6个月的数据。所以，我需要归档一些行。我现正探讨以下方法：
Sybase中的最接近于我试图实现的方法。但是，它要求您预先
浏览 4提问于2020-03-20得票数 0
在C#或VB.NET中，在Windows中的.NET Framework4.x下，我想编写一个通用函数，以便在运行时为指定的控件属性类型调用默认的UI编辑器。= this.ListBox1;我需要帮助了解这是否是实现这种功能的正确方法我研究并发现了这个答案，它演示了如何定
浏览 6提问于2022-10-20得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
