A C D E F G H I L N O P R S T U

A

authenticate() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Authenticate to Openstack Keystone As well as returning the access token, the member fields token, endpointURI and objectLocationURI are set up for re-use.

C

configure(Configuration) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftFileSystemFactoryTempAuth

copy(Path, Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

copyObject(SwiftObjectPath, SwiftObjectPath, Header...) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Copy an object.

create(URI) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftFileSystemFactoryTempAuth

createContainer(String) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Create a container -if it already exists, do nothing

createDirectory(Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Create a directory

createManifestForPartUpload(Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Tell the Swift server to expect a multi-part upload by submitting a 0-byte file with the X-Object-Manifest header

D

delete(SwiftObjectPath, Header...) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Deletes object from swift.

delete(Path, boolean) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Delete the entire tree.

deleteObject(Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

deletes object from Swift

E

extractUris(String, Path) - Static method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

extracts URIs from json

F

findObjectsByPrefix(SwiftObjectPath, Header...) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Find objects under a prefix

G

getBlocksize() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Get the default blocksize of this (bound) filesystem

getBlocksizeKB() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Get the blocksize of this filesystem

getBufferSizeKB() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Get the buffer size in KB

getBufferSizeKB() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

getConnectTimeout() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

getContainer() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Get the container to which this client is bound

getContentLength(URI) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Returns object length

getContentLength(SwiftObjectPath) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Get the length of the remote object

getCorrectSwiftPath(Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Take a Hadoop path and return one which uses the URI prefix and authority of this FS.

getData(SwiftObjectPath, long, long) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Make an HTTP GET request to Swift to get a range of data in the object.

getData(SwiftObjectPath, Header...) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Get the path contents as an input stream.

getInstance(URI, Configuration) - Static method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Create an instance against a specific FS URI,

getObject(Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Get the object as an input stream

getObject(Path, long, long) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Get the input stream starting from a specific point.

getObjectHeaders(Path, boolean) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Get the HTTP headers, in case you really need the low-level metadata

getObjectLocation(SwiftObjectPath, Header...) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Returns object location as byte[]

getObjectLocation(Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Try to find the specific server(s) on which the data lives

getObjectMetadata(Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Get the metadata of an object

getObjectMetadata(Path, boolean) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Get the metadata of an object

getOperationStatistics() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Get the current operation statistics

getOperationStatistics() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Get the current operation statistics

getPartSizeKB() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Get the partition size in KB

getPartsizeKB() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

getProxyHost() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

getProxyPort() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

getRegion() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Get the region which this client is bound to

getRetryCount() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

getScheme() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftFileSystemFactoryTempAuth

getTenant() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Get the tenant to which this client is bound

getThrottleDelay() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

getThrottleDelay() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

getUsername() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Get the username this client identifies itself as

H

headRequest(String, SwiftObjectPath, Header...) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Issue a head request

I

initialize(URI, Configuration) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Initalize the filesystem store -this creates the REST client binding.

isLocationAware() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Is this client bound to a location aware Swift blobstore -that is, can you query for the location of partitions

isUsePublicURL() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

L

listDeepObjectsInDirectory(SwiftObjectPath, boolean, Header...) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Find objects in a directory

listSubPaths(Path, boolean, boolean) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

List all elements in this directory

N

NEWEST - Static variable in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Header that says "use newest version" -ensures that the query doesn't pick up older versions served by an eventually consistent filesystem (except in the special case of a network partition, at which point no guarantees about consistency can be made.

O

objectExists(Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Does the object exist

objectExists(SwiftObjectPath) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Does the object exist

org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http - package org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http

org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative - package org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative

P

pathToURI(SwiftObjectPath, URI) - Static method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Converts Swift path to URI to make request.

putRequest(SwiftObjectPath, Header...) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Issue a put request

R

rename(Path, Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Rename through copy-and-delete.

rmdir(Path) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

deletes a directory from Swift.

S

SwiftFileSystemFactoryTempAuth - Class in org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative

Simple factory for the Swift file system.

SwiftFileSystemFactoryTempAuth() - Constructor for class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftFileSystemFactoryTempAuth

SwiftNativeFileSystemStoreTempAuth - Class in org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative

File system store implementation.

SwiftNativeFileSystemStoreTempAuth() - Constructor for class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

SwiftRestClientTempAuth - Class in org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http

This implements the client-side of the Swift REST API The core actions put, get and query data in the Swift object store, after authenticationg the client.

T

throttle() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Insert a throttled wait if the throttle delay > 0

toString() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

toString() - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

U

upload(SwiftObjectPath, InputStream, long, Header...) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.http.SwiftRestClientTempAuth

Uploads file as Input Stream to Swift.

uploadFile(Path, InputStream, long) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Upload a file/input stream of a specific length.

uploadFilePart(Path, int, InputStream, long) - Method in class org.apache.flink.fs.openstackhadoop.shaded.org.apache.hadoop.fs.swift.snative.SwiftNativeFileSystemStoreTempAuth

Upload part of a larger file.

A C D E F G H I L N O P R S T U