入门
文档
切换导航
切换导航
关于
入门
文档
通用
语言
运行器
I/O 连接器
路线图
社区
贡献
博客
案例研究
Apache
ASF 主页
许可证
安全
感谢
赞助
行为准则
关于
入门
文档
通用
语言
运行器
I/O 连接器
路线图
社区
贡献
博客
案例研究
Apache
ASF 主页
许可证
安全
感谢
赞助
行为准则
文档
使用文档
概念
Beam 模型基础
Beam 如何执行管道
Beam 编程指南
概述
管道
PCollection
创建 PCollection
PCollection 特性
转换
应用转换
核心 Beam 转换
ParDo
GroupByKey
CoGroupByKey
Combine
Flatten
Partition
用户代码要求
侧输入
额外输出
复合转换
管道 I/O
使用 I/O 转换
I/O 连接器
I/O 连接器指南
Apache Parquet I/O 连接器
Hadoop 输入/输出格式 I/O
HCatalog I/O
Google BigQuery I/O 连接器
Snowflake I/O 连接器
CDAP I/O 连接器
Spark Receiver I/O 连接器
SingleStoreDB I/O 连接器
Web API I/O 连接器
开发新的 I/O 连接器
概述:开发连接器
开发连接器 (Java)
开发连接器 (Python)
I/O 标准
测试 I/O 转换
模式
什么是模式
编程语言类型的模式
模式定义
逻辑类型
创建模式
使用模式
数据编码和类型安全
数据编码基础
指定编码器
默认编码器和 CoderRegistry
窗口
窗口基础
提供的窗口函数
设置 PCollection 的窗口函数
水印和延迟数据
向 PCollection 的元素添加时间戳
触发器
触发器基础
事件时间触发器和默认触发器
处理时间触发器
数据驱动触发器
设置触发器
复合触发器
指标
指标基础
指标类型
查询指标
在管道中使用指标
导出指标
状态和计时器
状态类型
延迟状态读取
计时器
垃圾收集状态
状态和计时器示例
可拆分 DoFns
基础
大小和进度
用户启动的检查点
运行器启动的拆分
水印估计
在排水期间截断
捆绑包完成
多语言管道
创建跨语言转换
使用跨语言转换
运行器支持
批处理 DoFns
转换服务
管道开发生命周期
设计您的管道
创建您的管道
测试您的管道
常见管道模式
概述
文件处理
侧输入
管道选项
自定义 I/O
自定义窗口
BigQueryIO
AI 平台
模式
BigQuery ML
对元素进行分组以进行有效的外部服务调用
使用共享对象进行缓存
AI/ML 管道
AI/ML 入门
关于 Beam ML
预测和推理
概述
构建具有多个模型的管道
使用 TensorRT 构建自定义模型处理程序
使用 LLM 推理
构建多语言推理管道
更新生产环境中的模型
数据处理
预处理数据
探索您的数据
工作流编排
使用 ML-OPS 工作流编排器
模型训练
每个实体的训练
在线聚类
ML 模型评估
用例
构建异常检测管道
参考
RunInference 指标
模型验证
运行时系统
容器环境
资源提示
SDK 运行配置
转换目录
Python
概述
逐元素
丰富
概述
Bigtable 示例
Vertex AI 特征存储示例
筛选
FlatMap
密钥
KvSwap
映射
MLTransform
ParDo
Partition
正则表达式
Reify
RunInference
概述
PyTorch 示例
Sklearn 示例
ToString
值
WithTimestamps
聚合
ApproximateQuantiles
ApproximateUnique
BatchElements
CoGroupByKey
CombineGlobally
CombinePerKey
CombineValues
计数
Distinct
GroupBy
GroupByKey
GroupIntoBatches
Latest
最大值
平均值
最小值
采样
求和
Top
ToList
其他
创建
Flatten
Reshuffle
WindowInto
Java
概述
逐元素
筛选
FlatMapElements
密钥
KvSwap
MapElements
ParDo
Partition
正则表达式
Reify
ToString
值
WithKeys
WithTimestamps
聚合
ApproximateQuantiles
ApproximateUnique
CoGroupByKey
Combine
CombineWithContext
计数
Distinct
GroupByKey
GroupIntoBatches
HllCount
Latest
最大值
平均值
最小值
采样
求和
Top
其他
创建
Flatten
PAssert
View
Window
词汇表
Beam Wiki
示例
相关转换
密钥
Javadoc
获取键值对集合,并返回每个元素的键。
示例
相关转换
KvSwap
交换键值对的值。
Values
用于提取每个元素的值。
WithKeys
用于为每个元素添加键。
最后更新于 2024/10/31
您是否找到了您要找的一切?
所有内容是否都有用且清晰?您想更改任何内容吗?请告诉我们!
发送反馈