import com.google.cloud.Page; //导入依赖的package包/类
/**
 * Example of listing the tables in a dataset.
 */
// [TARGET listTables(DatasetId, TableListOption...)]
// [VARIABLE "my_project_id"]
// [VARIABLE "my_dataset_name"]
public Page<Table> listTablesFromId(String projectId, String datasetName) {
  // [START listTablesFromId]
  DatasetId datasetId = DatasetId.of(projectId, datasetName);
  Page<Table> tables = bigquery.listTables(datasetId, TableListOption.pageSize(100));
  Iterator<Table> tableIterator = tables.iterateAll();
  while (tableIterator.hasNext()) {
    Table table = tableIterator.next();
    // do something with the table
  }
  // [END listTablesFromId]
  return tables;
}
 

import com.google.cloud.Page; //导入依赖的package包/类
/**
 * Example of listing table rows, specifying the page size.
 */
// [TARGET listTableData(String, String, TableDataListOption...)]
// [VARIABLE "my_dataset_name"]
// [VARIABLE "my_table_name"]
public Page<List<FieldValue>> listTableData(String datasetName, String tableName) {
  // [START listTableData]
  Page<List<FieldValue>> tableData =
      bigquery.listTableData(datasetName, tableName, TableDataListOption.pageSize(100));
  Iterator<List<FieldValue>> rowIterator = tableData.iterateAll();
  while (rowIterator.hasNext()) {
    List<FieldValue> row = rowIterator.next();
    // do something with the row
  }
  // [END listTableData]
  return tableData;
}
 

import com.google.cloud.Page; //导入依赖的package包/类
/**
 * Example of listing table rows, specifying the page size.
 */
// [TARGET listTableData(TableId, TableDataListOption...)]
// [VARIABLE "my_dataset_name"]
// [VARIABLE "my_table_name"]
public Page<List<FieldValue>> listTableDataFromId(String datasetName, String tableName) {
  // [START listTableDataFromId]
  TableId tableIdObject = TableId.of(datasetName, tableName);
  Page<List<FieldValue>> tableData =
      bigquery.listTableData(tableIdObject, TableDataListOption.pageSize(100));
  Iterator<List<FieldValue>> rowIterator = tableData.iterateAll();
  while (rowIterator.hasNext()) {
    List<FieldValue> row = rowIterator.next();
    // do something with the row
  }
  // [END listTableDataFromId]
  return tableData;
}
 

import com.google.cloud.Page; //导入依赖的package包/类
private static Blob blobExistsInner(URI uri) {
  final String bucketName = uri.getAuthority();
  final String prefix = uri.getPath().startsWith("/") ? uri.getPath().substring(1) : uri.getPath();

  final Page<Blob> list = STORAGE.list(bucketName, prefix(prefix));
  final Iterator<Blob> blobIterator = list.iterateAll();

  Blob blob = null;
  while (blobIterator.hasNext()) {
    blob = blobIterator.next();
    if (blob.getName().equals(prefix)) {
      break;
    }
  }

  if (blob != null) {
    return blob;
  } else {
    throw new NotReady();
  }
}
 

import com.google.cloud.Page; //导入依赖的package包/类
/**
 * Example of listing datasets, specifying the page size.
 */
// [TARGET listDatasets(DatasetListOption...)]
public Page<Dataset> listDatasets() {
  // [START listDatasets]
  Page<Dataset> datasets = bigquery.listDatasets(DatasetListOption.pageSize(100));
  Iterator<Dataset> datasetIterator = datasets.iterateAll();
  while (datasetIterator.hasNext()) {
    Dataset dataset = datasetIterator.next();
    // do something with the dataset
  }
  // [END listDatasets]
  return datasets;
}
 

import com.google.cloud.Page; //导入依赖的package包/类
/**
 * Example of listing the tables in a dataset, specifying the page size.
 */
// [TARGET listTables(String, TableListOption...)]
// [VARIABLE "my_dataset_name"]
public Page<Table> listTables(String datasetName) {
  // [START listTables]
  Page<Table> tables = bigquery.listTables(datasetName, TableListOption.pageSize(100));
  Iterator<Table> tableIterator = tables.iterateAll();
  while (tableIterator.hasNext()) {
    Table table = tableIterator.next();
    // do something with the table
  }
  // [END listTables]
  return tables;
}
 

import com.google.cloud.Page; //导入依赖的package包/类
/**
 * Example of listing jobs, specifying the page size.
 */
// [TARGET listJobs(JobListOption...)]
public Page<Job> listJobs() {
  // [START listJobs]
  Page<Job> jobs = bigquery.listJobs(JobListOption.pageSize(100));
  Iterator<Job> jobIterator = jobs.iterateAll();
  while (jobIterator.hasNext()) {
    Job job = jobIterator.next();
    // do something with the job
  }
  // [END listJobs]
  return jobs;
}
 

import com.google.cloud.Page; //导入依赖的package包/类
private List<List<Object>> readAllRows(String tableName) {
  Table table = bigQuery.getTable(dataset, tableName);
  Schema schema = table.getDefinition().getSchema();
  Page<List<FieldValue>> page = table.list();

  List<List<Object>> rows = new ArrayList<>();
  while (page != null) {
    for (List<FieldValue> row : page.getValues()) {
      rows.add(convertRow(schema.getFields(), row));
    }
    page = page.getNextPage();
  }
  return rows;
}
 

import com.google.cloud.Page; //导入依赖的package包/类
@Override
public Set<String> listDatasets() throws IOException {
    BigQuery bigquery = BigQueryConnection.createClient(properties.getDatastoreProperties());
    Page<Dataset> datasets = bigquery.listDatasets(properties.getDatastoreProperties().projectName.getValue(),
            BigQuery.DatasetListOption.pageSize(100));
    Set<String> datasetsName = new HashSet<>();
    Iterator<Dataset> datasetIterator = datasets.iterateAll();
    while (datasetIterator.hasNext()) {
        datasetsName.add(datasetIterator.next().getDatasetId().getDataset());
    }
    return datasetsName;
}
 

import com.google.cloud.Page; //导入依赖的package包/类
@Override
public Set<String> listTables() throws IOException {
    BigQuery bigquery = BigQueryConnection.createClient(properties.getDatastoreProperties());
    DatasetId datasetId = DatasetId.of(properties.getDatastoreProperties().projectName.getValue(),
            properties.bqDataset.getValue());
    Page<Table> tables = bigquery.listTables(datasetId, BigQuery.TableListOption.pageSize(100));
    Set<String> tablesName = new HashSet<>();
    Iterator<Table> tableIterator = tables.iterateAll();
    while (tableIterator.hasNext()) {
        tablesName.add(tableIterator.next().getTableId().getTable());
    }
    return tablesName;
}