in src/main/java/com/google/solutions/df/log/aggregations/common/Util.java [151:159]
public static String getClusterDetails(String gcsPath) {
GcsPath path = GcsPath.fromUri(URI.create(gcsPath));
Storage storage = StorageOptions.getDefaultInstance().getService();
BlobId blobId = BlobId.of(path.getBucket(), path.getObject());
byte[] content = storage.readAllBytes(blobId);
String contentString = new String(content, UTF_8);
LOG.debug("Query: {}", contentString);
return contentString;
}