in jdbc-grpc-client/src/main/java/org/apache/kyuubi/grpc/client/SimpleBlockingJdbcClient.java [376:386]
public DirectStatusResp createStatement(String connectionId, Optional<String> statementId) {
CreateStatementReq.Builder builder = CreateStatementReq.newBuilder();
builder.setConnectionId(ConnectionHandle.newBuilder().setId(connectionId).build());
if (statementId.isPresent()) {
StatementHandle handle = StatementHandle.newBuilder()
.setId(statementId.get())
.build();
builder.setStatementId(handle);
}
return statementBlockingStub.createStatement(builder.build());
}