import com.google.api.services.bigquery.model.DatasetList; //导入依赖的package包/类
static List<DatasetList.Datasets> listDatasets(Bigquery bq, String projectId, Predicate<DatasetList.Datasets> needle)
        throws IOException
{
    List<DatasetList.Datasets> datasets = new ArrayList<>();
    Bigquery.Datasets.List req = bq.datasets().list(projectId);
    DatasetList datasetList;
    do {
        datasetList = req.execute();
        if (datasetList.getDatasets() != null) {
            datasetList.getDatasets().stream()
                    .filter(needle)
                    .forEach(datasets::add);
        }
        req.setPageToken(datasetList.getNextPageToken());
    }
    while (null != datasetList.getNextPageToken());
    return datasets;
}
 

import com.google.api.services.bigquery.model.DatasetList; //导入依赖的package包/类
static void cleanupBq(Bigquery bq, String gcpProjectId)
        throws IOException
{
    if (bq == null) {
        return;
    }
    List<DatasetList.Datasets> datasets = listDatasets(
            bq, gcpProjectId, ds -> ds.getDatasetReference().getDatasetId().contains(BQ_TAG));
    for (DatasetList.Datasets dataset : datasets) {
        deleteDataset(bq, gcpProjectId, dataset.getDatasetReference().getDatasetId());
    }
}