com.google.api.services.storage.model.Objects类的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(9.6k)|赞(0)|评价(0)|浏览(97)

本文整理了Java中com.google.api.services.storage.model.Objects类的一些代码示例，展示了Objects类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Objects类的具体详情如下：
包路径：com.google.api.services.storage.model.Objects
类名称：Objects

Objects介绍

暂无

代码示例

代码示例来源：origin: apache/ignite

  1. /** {@inheritDoc} */
  2. @Override public Collection<InetSocketAddress> getRegisteredAddresses() throws IgniteSpiException {
  3.   init();
  4.   Collection<InetSocketAddress> addrs = new ArrayList<>();
  5.   try {
  6.     Storage.Objects.List listObjects = storage.objects().list(bucketName);
  7.     com.google.api.services.storage.model.Objects objects;
  8.     do {
  9.       objects = listObjects.execute();
  10.       if (objects == null || objects.getItems() == null)
  11.         break;
  12.       for (StorageObject object : objects.getItems())
  13.         addrs.add(addrFromString(object.getName()));
  14.       listObjects.setPageToken(objects.getNextPageToken());
  15.     }
  16.     while (null != objects.getNextPageToken());
  17.   }
  18.   catch (Exception e) {
  19.     throw new IgniteSpiException("Failed to get content from the bucket: " + bucketName, e);
  20.   }
  21.   return addrs;
  22. }

代码示例来源：origin: googleapis/google-cloud-java

  1. Iterable<StorageObject> storageObjects =
  2.    Iterables.concat(
  3.      firstNonNull(objects.getItems(), ImmutableList.<StorageObject>of()),
  4.      objects.getPrefixes() != null
  5.        ? Lists.transform(objects.getPrefixes(), objectFromPrefix(bucket))
  6.        : ImmutableList.<StorageObject>of());
  7.  return Tuple.of(objects.getNextPageToken(), storageObjects);
  8. } catch (IOException ex) {
  9.  span.setStatus(Status.UNKNOWN.withDescription(ex.getMessage()));

代码示例来源：origin: Netflix/Priam

  1. private Iterator<String> createIterator() throws Exception {
  2.   if (listObjectsSrvcHandle == null) initListing();
  3.   List<String> temp = Lists.newArrayList(); // a container of results
  4.   // Sends the metadata request to the server and returns the parsed metadata response.
  5.   this.objectsContainerHandle = listObjectsSrvcHandle.execute();
  6.   for (StorageObject object : this.objectsContainerHandle.getItems()) {
  7.     // processing a page of results
  8.     temp.add(object.getName());
  9.   }
  10.   return temp.iterator();
  11. }

代码示例来源：origin: Netflix/Priam

  1. @Override
  2. public boolean hasNext() {
  3.   if (this.iterator.hasNext()) {
  4.     return true;
  5.   }
  6.   while (this.objectsContainerHandle.getNextPageToken() != null && !iterator.hasNext())
  7.     try { // if here, you have iterated through all elements of the previous page, now, get
  8.       // the next page of results
  9.       this.listObjectsSrvcHandle.setPageToken(objectsContainerHandle.getNextPageToken());
  10.       this.iterator = createIterator();
  11.     } catch (Exception e) {
  12.       throw new RuntimeException(
  13.           "Exception encountered fetching elements, see previous messages for details.",
  14.           e);
  15.     }
  16.   return this.iterator.hasNext();
  17. }

代码示例来源：origin: org.apache.beam/beam-sdks-java-extensions-google-cloud-platform-core

  1. @Test
  2. public void testMatch() throws Exception {
  3.  Objects modelObjects = new Objects();
  4.  List<StorageObject> items = new ArrayList<>();
  5.  items.add(createStorageObject("gs://testbucket/testdirectory/anotherfile", 6L /* fileSize */));
  6.  modelObjects.setItems(items);
  7.  when(mockGcsUtil.listObjects(eq("testbucket"), anyString(), isNull(String.class)))
  8.    .thenReturn(modelObjects);

代码示例来源：origin: stackoverflow.com

  1. o = new Objects(){
  2.   @Override
  3.   public void myAbstractMethod(){
  4.    ...
  5.   }
  6. }

代码示例来源：origin: spinnaker/kayenta

  1. private StorageObject resolveSingularItem(ObjectType objectType, String objectKey, GoogleNamedAccountCredentials credentials, Storage storage, String bucketName) {
  2.  String rootFolder = daoRoot(credentials, objectType.getGroup()) + "/" + objectKey;
  3.  try {
  4.   Storage.Objects.List objectsList = storage.objects().list(bucketName).setPrefix(rootFolder);
  5.   Objects objects = objectsList.execute();
  6.   List<StorageObject> items = objects.getItems();
  7.   if (items != null && items.size() == 1) {
  8.    return items.get(0);
  9.   } else {
  10.    throw new IllegalArgumentException("Unable to resolve singular " + objectType + " at " + daoRoot(credentials, objectType.getGroup()) + '/' + objectKey + ".");
  11.   }
  12.  } catch (IOException e) {
  13.   throw new IllegalArgumentException("Could not fetch items from Google Cloud Storage: " + e.getMessage(), e);
  14.  }
  15. }

代码示例来源：origin: org.apache.beam/beam-sdks-java-extensions-google-cloud-platform-core

  1. Storage.Objects.List mockStorageList = Mockito.mock(Storage.Objects.List.class);
  2. Objects modelObjects = new Objects();
  3. List<StorageObject> items = new ArrayList<>();
  4. items.add(new StorageObject().setBucket("testbucket").setName("test/file4.txt"));
  5. modelObjects.setItems(items);

代码示例来源：origin: apache/incubator-druid

  1. do {
  2.  objects = listObjects.execute();
  3.  List<StorageObject> items = objects.getItems();
  4.  if (items != null) {
  5.   for (StorageObject item : items) {
  6. } while (objects.getNextPageToken() != null);

代码示例来源：origin: com.google.gcloud/gcloud-java-storage

  1. @Override
  2. public Tuple<String, Iterable<StorageObject>> list(final String bucket, Map<Option, ?> options) {
  3.  try {
  4.   Objects objects = storage.objects()
  5.     .list(bucket)
  6.     .setProjection(DEFAULT_PROJECTION)
  7.     .setVersions(VERSIONS.getBoolean(options))
  8.     .setDelimiter(DELIMITER.getString(options))
  9.     .setPrefix(PREFIX.getString(options))
  10.     .setMaxResults(MAX_RESULTS.getLong(options))
  11.     .setPageToken(PAGE_TOKEN.getString(options))
  12.     .setFields(FIELDS.getString(options))
  13.     .execute();
  14.   Iterable<StorageObject> storageObjects = Iterables.concat(
  15.     firstNonNull(objects.getItems(), ImmutableList.<StorageObject>of()),
  16.     objects.getPrefixes() != null
  17.       ? Lists.transform(objects.getPrefixes(), objectFromPrefix(bucket))
  18.       : ImmutableList.<StorageObject>of());
  19.   return Tuple.of(objects.getNextPageToken(), storageObjects);
  20.  } catch (IOException ex) {
  21.   throw translate(ex);
  22.  }
  23. }

代码示例来源：origin: pliablematter/simple-cloud-storage

  1. /**
  2.  * Lists the objects in a bucket
  3.  * 
  4.  * @param bucketName bucket name to list
  5.  * @return Array of object names
  6.  * @throws Exception
  7.  */
  8. public static List<String> listBucket(String bucketName) throws Exception {
  9.   
  10.   Storage storage = getStorage();
  11.   
  12.   List<String> list = new ArrayList<String>();
  13.   
  14.   List<StorageObject> objects = storage.objects().list(bucketName).execute().getItems();
  15.   if(objects != null) {
  16.     for(StorageObject o : objects) {
  17.       list.add(o.getName());
  18.     }
  19.   }
  20.   
  21.   return list;
  22. }

代码示例来源：origin: org.apache.beam/beam-sdks-java-extensions-google-cloud-platform-core

  1. @Test
  2. public void testGlobExpansion() throws IOException {
  3.  Objects modelObjects = new Objects();
  4.  List<StorageObject> items = new ArrayList<>();
  5.    createStorageObject("gs://testbucket/testotherdirectory/file4name", 6L /* fileSize */));
  6.  modelObjects.setItems(items);

代码示例来源：origin: google/google-api-java-client-samples

  1. public static Iterable<StorageObject> list(Storage storage, String bucketName)
  2.   throws IOException {
  3.  List<List<StorageObject>> pagedList = Lists.newArrayList();
  4.  Storage.Objects.List listObjects = storage.objects().list(bucketName);
  5.  Objects objects;
  6.  do {
  7.   objects = listObjects.execute();
  8.   List<StorageObject> items = objects.getItems();
  9.   if (items != null) {
  10.    pagedList.add(objects.getItems());
  11.   }
  12.   listObjects.setPageToken(objects.getNextPageToken());
  13.  } while (objects.getNextPageToken() != null);
  14.  return Iterables.concat(pagedList);
  15. }

代码示例来源：origin: com.google.cloud.bigdataoss/gcsio

  1. List<String> pagePrefixes = items.getPrefixes();
  2. if (pagePrefixes != null) {
  3.  logger.atFine().log("listed %s prefixes", pagePrefixes.size());
  4. List<StorageObject> objects = items.getItems();
  5. if (objects != null) {
  6.  logger.atFine().log("listed %s objects", objects.size());
  7. listedPrefixes.addAll(prefixes);
  8. return items.getNextPageToken();

代码示例来源：origin: org.apache.beam/beam-sdks-java-extensions-google-cloud-platform-core

  1. Storage.Objects.List mockStorageList = Mockito.mock(Storage.Objects.List.class);
  2. Objects modelObjects = new Objects();
  3. List<StorageObject> items = new ArrayList<>();
  4. items.add(new StorageObject().setBucket("testbucket").setName("testdirectory/anotherfile"));
  5. modelObjects.setItems(items);

代码示例来源：origin: GoogleCloudPlatform/java-docs-samples

  1. /**
  2.  * Fetch a list of the objects within the given bucket.
  3.  *
  4.  * @param bucketName the name of the bucket to list.
  5.  * @return a list of the contents of the specified bucket.
  6.  */
  7. public static List<StorageObject> listBucket(String bucketName)
  8.   throws IOException, GeneralSecurityException {
  9.  Storage client = StorageFactory.getService();
  10.  Storage.Objects.List listRequest = client.objects().list(bucketName);
  11.  List<StorageObject> results = new ArrayList<StorageObject>();
  12.  Objects objects;
  13.  // Iterate through each page of results, and add them to our results list.
  14.  do {
  15.   objects = listRequest.execute();
  16.   // Add the items in this page of results to the list we'll return.
  17.   results.addAll(objects.getItems());
  18.   // Get the next page, in the next iteration of this loop.
  19.   listRequest.setPageToken(objects.getNextPageToken());
  20.  } while (null != objects.getNextPageToken());
  21.  return results;
  22. }
  23. // [END list_bucket]

代码示例来源：origin: com.google.cloud/google-cloud-storage

  1. Iterable<StorageObject> storageObjects =
  2.    Iterables.concat(
  3.      firstNonNull(objects.getItems(), ImmutableList.<StorageObject>of()),
  4.      objects.getPrefixes() != null
  5.        ? Lists.transform(objects.getPrefixes(), objectFromPrefix(bucket))
  6.        : ImmutableList.<StorageObject>of());
  7.  return Tuple.of(objects.getNextPageToken(), storageObjects);
  8. } catch (IOException ex) {
  9.  span.setStatus(Status.UNKNOWN.withDescription(ex.getMessage()));

代码示例来源：origin: spinnaker/kayenta

  1. List<StorageObject> items = objects.getItems();
  2.   objectsList.setPageToken(objects.getNextPageToken());
  3.  } while (objects.getNextPageToken() != null);
  4. } catch (IOException e) {
  5.  log.error("Could not fetch items from Google Cloud Storage: {}", e);

代码示例来源：origin: com.netflix.spinnaker.clouddriver/clouddriver-appengine

  1. List<StorageObject> items = objects.getItems();
  2.  if (items != null) {
  3.   for (StorageObject obj : items) {
  4.  listMethod.setPageToken(objects.getNextPageToken());
  5. } while (objects.getNextPageToken() != null);
  6. executor.shutdown();

代码示例来源：origin: org.apache.beam/beam-sdks-java-extensions-google-cloud-platform-core

  1. do {
  2.  Objects objects = options.getGcsUtil().listObjects(gcsPattern.getBucket(), prefix, pageToken);
  3.  if (objects.getItems() == null) {
  4.   break;
  5.  for (StorageObject o : objects.getItems()) {
  6.   String name = o.getName();
  7.  pageToken = objects.getNextPageToken();
  8. } while (pageToken != null);
  9. return MatchResult.create(Status.OK, results);

内容来源于网络，如有侵权，请联系作者删除！

Objects

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com