GcsIOChannelFactory (Apache Beam SDK for Java, version 0.7.0-SNAPSHOT API)

public class GcsIOChannelFactory
extends Object
implements IOChannelFactory

Implements IOChannelFactory for GCS.

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`copy(Iterable<String> srcFilenames, Iterable<String> destFilenames)`
`WritableByteChannel`	`create(String spec, String mimeType)`
`static GcsIOChannelFactory`	`fromOptions(PipelineOptions options)` Create a `GcsIOChannelFactory` with the given `PipelineOptions`.
`long`	`getSizeBytes(String spec)`
`boolean`	`isReadSeekEfficient(String spec)`
`Collection<String>`	`match(String spec)`
`ReadableByteChannel`	`open(String spec)`
`void`	`remove(Collection<String> filesOrDirs)`
`String`	`resolve(String path, String other)`
`Path`	`toPath(String path)`

public static GcsIOChannelFactory fromOptions(PipelineOptions options)

public Collection<String> match(String spec)
                         throws IOException

public ReadableByteChannel open(String spec)
                         throws IOException

public WritableByteChannel create(String spec,
                                  String mimeType)
                           throws IOException

public boolean isReadSeekEfficient(String spec)
                            throws IOException

public String resolve(String path,
                      String other)
               throws IOException

public void copy(Iterable<String> srcFilenames,
                 Iterable<String> destFilenames)
          throws IOException

public void remove(Collection<String> filesOrDirs)
            throws IOException

Class GcsIOChannelFactory