如何在BigQuery Java客户端中复用会话以跨查询使用临时表

要在多个查询中复用会话访问临时表，核心是保存第一次创建会话时返回的会话ID，并在后续所有查询中指定该ID，具体步骤如下：

1. 创建会话并获取会话ID
   执行创建临时表的查询时，通过返回的QueryResult提取会话ID：

BigQuery bigQuery = ....
// 构建创建临时表的查询配置，开启会话创建
QueryJobConfiguration createTableConfig = QueryJobConfiguration.newBuilder(
    "CREATE TEMP TABLE _SESSION.tmp_01 AS SELECT ....."
)
.setCreateSession(true)
.build();

// 执行查询并获取会话ID
QueryResult createResult = bigQuery.query(createTableConfig);
String sessionId = createResult.getSessionId();

2. 后续查询复用会话ID
   在后续需要访问临时表的查询配置中，通过setSessionId()指定之前获取的会话ID：

// 构建查询临时表的配置，指定复用的会话ID
QueryJobConfiguration queryConfig = QueryJobConfiguration.newBuilder(
    "SELECT DISTINCT * FROM _SESSION.tmp_01"
)
.setSessionId(sessionId) // 关键：绑定到已创建的会话
.build();

// 执行查询即可正常访问临时表
QueryResult queryResult = bigQuery.query(queryConfig);

注意事项 #

• 会话默认生命周期为24小时，超时后会自动销毁，关联的临时表也会被删除
• 所有需要访问该临时表的后续查询，必须统一使用同一个会话ID
• 如果采用异步作业方式（bigQuery.create(JobInfo)），可从执行完成的Job对象中提取会话ID

内容的提问来源于stack exchange，提问作者swist