在Beam中，可以使用SQL查詢來操作數據。SQL查詢的方法如下：
PCollection對象，該對象表示要操作的數據集。SqlTransform將SQL查詢語句應用到數據集中，生成一個新的PCollection對象。PAssert來驗證查詢結果是否與預期結果一致。示例代碼如下：
PCollection<Row> data = ...; // 創建一個數據集對象
String query = "SELECT * FROM PCOLLECTION WHERE column = 'value'"; // SQL查詢語句
PCollection<Row> result = data.apply(SqlTransform.query(query)); // 應用SQL查詢
PAssert.that(result).containsInAnyOrder(expectedResults); // 驗證查詢結果是否與預期結果一致
通過以上步驟，可以使用SQL查詢來操作Beam中的數據集。
