開始使用
文件
切換導覽
切換導覽
關於
開始使用
文件
一般
語言
執行器 (Runners)
輸入/輸出連接器 (I/O Connectors)
路線圖 (Roadmap)
社群
貢獻
部落格
案例研究
Apache
ASF 首頁
授權條款
安全性
感謝
贊助
行為準則
關於
開始使用
文件
一般
語言
執行器 (Runners)
輸入/輸出連接器 (I/O Connectors)
路線圖
社群
貢獻
部落格
案例研究
Apache
ASF 首頁
授權條款
安全性
感謝
贊助
行為準則
文件
使用文件
概念
Beam 模型基礎
Beam 如何執行管線
Beam 程式設計指南
概述
管線 (Pipelines)
PCollections
建立 PCollection
PCollection 特性
轉換 (Transforms)
套用轉換
核心 Beam 轉換
ParDo
GroupByKey
CoGroupByKey
Combine
Flatten
Partition
使用者程式碼的要求
側邊輸入 (Side inputs)
額外輸出
複合轉換
管線輸入/輸出 (Pipeline I/O)
使用輸入/輸出轉換
輸入/輸出連接器
輸入/輸出連接器指南
Apache Parquet 輸入/輸出連接器
Hadoop 輸入/輸出格式 I/O
HCatalog I/O
Google BigQuery 輸入/輸出連接器
Snowflake 輸入/輸出連接器
CDAP 輸入/輸出連接器
Spark Receiver 輸入/輸出連接器
SingleStoreDB 輸入/輸出連接器
Web APIs 輸入/輸出連接器
開發新的輸入/輸出連接器
概述：開發連接器
開發連接器 (Java)
開發連接器 (Python)
輸入/輸出標準
測試輸入/輸出轉換
綱要 (Schemas)
什麼是綱要
程式語言類型的綱要
綱要定義
邏輯類型
建立綱要
使用綱要
資料編碼和類型安全
資料編碼基礎
指定編碼器
預設編碼器和 CoderRegistry
視窗化 (Windowing)
視窗化基礎
提供的視窗化函式
設定 PCollection 的視窗化函式
浮水印和遲到資料
將時間戳記新增至 PCollection 的元素
觸發器 (Triggers)
觸發器基礎
事件時間觸發器和預設觸發器
處理時間觸發器
資料驅動觸發器
設定觸發器
複合觸發器
指標 (Metrics)
指標基礎
指標類型
查詢指標
在管線中使用指標
匯出指標
狀態和計時器 (State and Timers)
狀態類型
延遲狀態讀取
計時器
垃圾回收狀態
狀態和計時器範例
可分割的 DoFn (Splittable DoFns)
基礎
大小和進度
使用者起始檢查點
執行器起始分割
浮水印估計
在排空期間截斷
捆綁最終化
多語言管線
建立跨語言轉換
使用跨語言轉換
執行器支援
批次 DoFn (Batched DoFns)
轉換服務
管線開發生命週期
設計您的管線
建立您的管線
測試您的管線
常見管線模式
概述
檔案處理
側邊輸入 (Side inputs)
管線選項
自訂輸入/輸出
自訂視窗
BigQueryIO
AI 平台
綱要
BigQuery ML
將元素分組以進行有效率的外部服務呼叫
使用共享物件進行快取
AI/ML 管線
開始使用 AI/ML
關於 Beam ML
預測和推論
概述
建構具有多個模型的管線
使用 TensorRT 建構自訂模型處理器
使用 LLM 推論
建構多語言推論管線
在生產環境中更新模型
資料處理
預處理資料
探索您的資料
工作流程協調
使用 ML-OPS 工作流程協調器
模型訓練
每個實體的訓練
線上叢集
ML 模型評估
使用案例
建構異常偵測管線
參考
RunInference 指標
模型驗證
執行階段系統
容器環境
資源提示
SDK Harness 設定
轉換目錄
Python
概述
元素層級
擴充
概述
Bigtable 範例
Vertex AI Feature Store 範例
Filter
FlatMap
Keys
KvSwap
Map
MLTransform
ParDo
Partition
正規表示式 (Regex)
Reify
RunInference
概述
PyTorch 範例
Sklearn 範例
ToString
Values
WithTimestamps
彙總
ApproximateQuantiles
ApproximateUnique
BatchElements
CoGroupByKey
CombineGlobally
CombinePerKey
CombineValues
Count
Distinct
GroupBy
GroupByKey
GroupIntoBatches
Latest
Max
Mean
Min
Sample
Sum
Top
ToList
其他
Create
Flatten
Reshuffle
WindowInto
Java
概述
元素層級
Filter
FlatMapElements
Keys
KvSwap
MapElements
ParDo
Partition
正規表示式 (Regex)
Reify
ToString
Values
WithKeys
WithTimestamps
彙總
ApproximateQuantiles
ApproximateUnique
CoGroupByKey
Combine
CombineWithContext
Count
Distinct
GroupByKey
GroupIntoBatches
HllCount
Latest
Max
Mean
Min
Sample
Sum
Top
其他
Create
Flatten
PAssert
View
Window
詞彙表
Beam Wiki
範例
相關轉換
正規表示式 (Regex)
Javadoc
提供各種基於正規表示式的功能。
範例
相關轉換
MapElements
上次更新於 2024/10/31
您是否找到了您要找的所有內容？
所有內容是否有用且清楚？ 您是否想要更改任何內容？ 請告訴我們！
傳送意見回饋
Javadoc
Javadoc