apache beam中的管道嵌套
-
null
-
null
共有1个答案
Apache Beam是一个很好的工具，用于通过TensorFlow对机器学习数据进行预处理。关于这个通用用例和tf.transform的更多信息可在本文中获得。
似乎没有任何描述表明需要“嵌套管道”。处理目录中每个文件的每一行是一个简单的textio.read转换。现在还不清楚您的需求是什么，但是，一般来说，将行分隔为浮点并与其他行连接是简单的ParDo和分组操作。
作为一般的指导，我会避免嵌套管道，并尝试分解问题以适合于单个管道。
-
我有一个数据流工作，将单个文件分割成x个记录（表）。这些流在bigQuery没有问题。 不过，我发现没有办法在结果出来后执行管道中的另一个阶段。 举个例子 根据上述内容，我希望运行以下内容： 是有无论如何运行管道的另一个部分后，up到bigQuery或这是不可能的？提前感谢。
-
在 Netty 4.1 中，是否可以创建子通道/管道或嵌套通道/管道？ 例如，我有一个管道，其中安装了各种编解码器，用于协议/序列化。在管道结束时，我将一条消息传递给我的应用程序级逻辑。过度简化的示例： 然后，这个应用逻辑的句柄方法可以执行它想要的任何顺序逻辑。这清楚地分离了我的应用程序级别逻辑，但是，我想利用Netty的ChannelPipeline提供的“拦截过滤器模式的高级形式”。我想将管道
-
问题内容： 我想在Jenkins管道中运行像这样的嵌套shell命令： 不幸的是，当我将其格式化为管道语法时： Jenkins似乎无法正确运行它们，但是输出： 我试图在bash下运行命令，如下所示： 在jenkins管道上运行bash命令， 但最终遇到类似的问题。任何想法如何解决这个问题？ 问题答案： 如果将shell命令扩展为两行，这对于Jenkins Pipeline来说将变得更加容易： 第一
-
问题内容： 在jenkinsfile，我已经通过指定的文件夹名 SparseCheckoutPaths 我想结帐。但是我却得到了整个分支结帐。 问题答案： 这是我自己的问题的答案。关于它如何工作的一些背景知识，有一个名为 sparsecheckout的 git客户端标志/配置，负责这种签出。此外，还需要一个 稀疏签出的 命名文件。 我的问题是 Jenkinsfile 的语法，正确的语法如下： 有关
-
无状态管道是纯粹的功能，通过输入数据流动而不记住任何东西或引起可检测的副作用。 大多数管道是无状态的。 我们使用的CurrencyPipe和我们创建的长度管是无状态管的示例。 状态管道是能够管理它们转换的数据的状态的管道。 创建HTTP请求，存储响应并显示输出的管道是有状态的管道。 有状态管道应谨慎使用。 Angular 2提供 ，这是有状态的。 View Example 实现有状态管道 // n
-
传递参数 链接管道 我们可以将多个管道连接在一起，以便在一个表达式中使用多个管道。