com.google.cloud.storage.contrib.nio

Class CloudStorageFileSystem

java.lang.Object

java.nio.file.FileSystem

com.google.cloud.storage.contrib.nio.CloudStorageFileSystem

All Implemented Interfaces:

Closeable, AutoCloseable

@ThreadSafe
public final class CloudStorageFileSystem
extends FileSystem

Google Cloud Storage FileSystem implementation.

See Also:

Concepts and Terminology, Bucket and Object Naming Guidelines

Field Summary

Fields

Modifier and Type	Field and Description
static String	BASIC_VIEW
static int	BLOCK_SIZE_DEFAULT
static FileTime	FILE_TIME_UNKNOWN
static String	GCS_VIEW
static Set<String>	SUPPORTED_VIEWS
static String	URI_SCHEME

Method Summary

Modifier and Type	Method and Description
String	bucket() Returns Cloud Storage bucket name being served by this file system.
void	close() Does nothing currently.
CloudStorageConfiguration	config() Returns configuration object for this file system instance.
boolean	equals(Object other)
static CloudStorageFileSystem	forBucket(String bucket) Returns Google Cloud Storage FileSystem object for bucket.
static CloudStorageFileSystem	forBucket(String bucket, CloudStorageConfiguration config) Creates new file system instance for bucket, with customizable settings.
static CloudStorageFileSystem	forBucket(String bucket, CloudStorageConfiguration config, StorageOptions storageOptions) Returns Google Cloud Storage FileSystem object for bucket.
Iterable<FileStore>	getFileStores() Returns nothing because Google Cloud Storage doesn't have disk partitions of limited size, or anything similar.
CloudStoragePath	getPath(String first, String... more) Converts Cloud Storage object name to a Path object.
PathMatcher	getPathMatcher(String syntaxAndPattern)
Iterable<Path>	getRootDirectories()
String	getSeparator() Returns .
UserPrincipalLookupService	getUserPrincipalLookupService() Throws UnsupportedOperationException because this feature hasn't been implemented yet.
int	hashCode()
boolean	isOpen() Returns true, even if you previously called the close() method.
boolean	isReadOnly() Returns false.
static Page<Bucket>	listBuckets(String project, Storage.BucketListOption... options) Lists the project's buckets.
WatchService	newWatchService() Throws UnsupportedOperationException because this feature hasn't been implemented yet.
CloudStorageFileSystemProvider	provider()
Set<String>	supportedFileAttributeViews()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

URI_SCHEME

public static final String URI_SCHEME

See Also:

Constant Field Values

GCS_VIEW

public static final String GCS_VIEW

See Also:

Constant Field Values

BASIC_VIEW

public static final String BASIC_VIEW

See Also:

Constant Field Values

BLOCK_SIZE_DEFAULT

public static final int BLOCK_SIZE_DEFAULT

See Also:

Constant Field Values

FILE_TIME_UNKNOWN

public static final FileTime FILE_TIME_UNKNOWN

SUPPORTED_VIEWS

public static final Set<String> SUPPORTED_VIEWS

Method Detail

listBuckets

public static Page<Bucket> listBuckets(@Nullable
                                       String project,
                                       Storage.BucketListOption... options)

Lists the project's buckets. Pass "null" to use the default project.

Example of listing buckets, specifying the page size and a name prefix.

 String prefix = "bucket_";
 Page<Bucket> buckets = CloudStorageFileSystem.listBuckets("my-project", BucketListOption.prefix(prefix));
 Iterator<Bucket> bucketIterator = buckets.iterateAll();
 while (bucketIterator.hasNext()) {
   Bucket bucket = bucketIterator.next();
   // do something with the bucket
 }
 

Throws:

StorageException - upon failure

forBucket

@CheckReturnValue
public static CloudStorageFileSystem forBucket(String bucket)

Returns Google Cloud Storage FileSystem object for bucket.

NOTE: You may prefer to use Java's standard API instead:

 FileSystem fs = FileSystems.getFileSystem(URI.create("gs://bucket"));
 

However some systems and build environments might be flaky when it comes to Java SPI. This is because services are generally runtime dependencies and depend on a META-INF file being present in your jar (generated by Google Auto at compile-time). In such cases, this method provides a simpler alternative.

See Also:

forBucket(String, CloudStorageConfiguration), FileSystems.getFileSystem(java.net.URI)

forBucket

@CheckReturnValue
public static CloudStorageFileSystem forBucket(String bucket,
                                                                 CloudStorageConfiguration config)

Creates new file system instance for bucket, with customizable settings.

See Also:

forBucket(String)

forBucket

@CheckReturnValue
public static CloudStorageFileSystem forBucket(String bucket,
                                                                 CloudStorageConfiguration config,
                                                                 @Nullable
                                                                 StorageOptions storageOptions)

Returns Google Cloud Storage FileSystem object for bucket.

Google Cloud Storage file system objects are basically free. You can create as many as you want, even if you have multiple instances for the same bucket. There's no actual system resources associated with this object. Therefore calling close() on the returned value is optional.

Note: It is also possible to instantiate this class via Java's FileSystems.getFileSystem(URI.create("gs://bucket")). We discourage you from using that if possible, for the reasons documented in CloudStorageFileSystemProvider.newFileSystem(URI, java.util.Map)

See Also:

FileSystems.getFileSystem(URI)

provider

public CloudStorageFileSystemProvider provider()

Specified by:

provider in class FileSystem

bucket

public String bucket()

Returns Cloud Storage bucket name being served by this file system.

config

public CloudStorageConfiguration config()

Returns configuration object for this file system instance.

getPath

public CloudStoragePath getPath(String first,
                                String... more)

Converts Cloud Storage object name to a Path object.

Specified by:

getPath in class FileSystem

close

public void close()
           throws IOException

Does nothing currently. This method might be updated in the future to close all channels associated with this file system object. However it's unlikely that even then, calling this method will become mandatory.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in class FileSystem

Throws:

IOException

isOpen

public boolean isOpen()

Returns true, even if you previously called the close() method.

Specified by:

isOpen in class FileSystem

isReadOnly

public boolean isReadOnly()

Returns false.

Specified by:

isReadOnly in class FileSystem

getSeparator

public String getSeparator()

Returns .

Specified by:

getSeparator in class FileSystem

getRootDirectories

public Iterable<Path> getRootDirectories()

Specified by:

getRootDirectories in class FileSystem

getFileStores

public Iterable<FileStore> getFileStores()

Returns nothing because Google Cloud Storage doesn't have disk partitions of limited size, or anything similar.

Specified by:

getFileStores in class FileSystem

supportedFileAttributeViews

public Set<String> supportedFileAttributeViews()

Specified by:

supportedFileAttributeViews in class FileSystem

getPathMatcher

public PathMatcher getPathMatcher(String syntaxAndPattern)

Specified by:

getPathMatcher in class FileSystem

getUserPrincipalLookupService

public UserPrincipalLookupService getUserPrincipalLookupService()

Throws UnsupportedOperationException because this feature hasn't been implemented yet.

Specified by:

getUserPrincipalLookupService in class FileSystem

newWatchService

public WatchService newWatchService()
                             throws IOException

Throws UnsupportedOperationException because this feature hasn't been implemented yet.

Specified by:

newWatchService in class FileSystem

Throws:

IOException

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object