code: @Override
    public Value<List<BigQueryLoadJobReference>> run(
        BigQueryStoreResult<GoogleCloudStorageFileSet> bigQueryStoreResult) throws Exception {
      BigQueryStoreResult<GoogleCloudStorageFileSet> outputResult = bigQueryStoreResult;
      List<GcsFilename> files = outputResult.getResult().getFiles();
      List<List<GcsFilename>> bundles =
          bundleFiles(files, BigQueryConstants.BIGQUERY_LOAD_DATA_SIZE_LIMIT);
      List<FutureValue<BigQueryLoadJobReference>> jobReferenceList = new ArrayList<>();
      for (List<GcsFilename> bundle : bundles) {
        jobReferenceList.add(futureCall(new BigQueryLoadFileSetJob(dataset, tableName, projectId,
            bundle, SerializableValue.of(Marshallers.getGenericJsonMarshaller(TableSchema.class),
                outputResult.getSchema())), immediate(Integer.valueOf(0))));
      }
      return futureList(jobReferenceList);
    }
docs: Divides the files into bundles having size less than or equal to the maximum size allowed per
  bigquery load {@link Job} and then starts separate pipeline jobs for each of the bundles.
  Returns a list of {@link JobReference}s.