A C D G H J N O P R S U
All Classes All Packages

A

applyHadoopConfigDefaults(Configuration) - Method in class org.apache.flink.fs.s3hadoop.S3FileSystemFactory

C

commitMultiPartUpload(String, String, List<CompletedPart>, long, AtomicInteger) - Method in class org.apache.flink.fs.s3hadoop.HadoopS3AccessHelper

COMPONENT - Static variable in class org.apache.flink.fs.s3.common.token.HadoopDynamicTemporaryAWSCredentialsProvider

createHadoopFileSystem() - Method in class org.apache.flink.fs.s3hadoop.S3FileSystemFactory

D

deleteObject(String) - Method in class org.apache.flink.fs.s3hadoop.HadoopS3AccessHelper

G

getInitURI(URI, Configuration) - Method in class org.apache.flink.fs.s3hadoop.S3FileSystemFactory

getObject(String, File) - Method in class org.apache.flink.fs.s3hadoop.HadoopS3AccessHelper

getObjectMetadata(String) - Method in class org.apache.flink.fs.s3hadoop.HadoopS3AccessHelper

getS3AccessHelper(FileSystem) - Method in class org.apache.flink.fs.s3hadoop.S3FileSystemFactory

getScheme() - Method in class org.apache.flink.fs.s3hadoop.S3AFileSystemFactory

getScheme() - Method in class org.apache.flink.fs.s3hadoop.S3FileSystemFactory

getSessionCredentials(String, String, String) - Method in class org.apache.flink.fs.s3hadoop.token.S3HadoopDelegationTokenProvider

H

HadoopDynamicTemporaryAWSCredentialsProvider - Class in org.apache.flink.fs.s3.common.token

Support dynamic session credentials for authenticating with AWS using SDK v2.

HadoopDynamicTemporaryAWSCredentialsProvider() - Constructor for class org.apache.flink.fs.s3.common.token.HadoopDynamicTemporaryAWSCredentialsProvider

HadoopDynamicTemporaryAWSCredentialsProvider(URI, Configuration) - Constructor for class org.apache.flink.fs.s3.common.token.HadoopDynamicTemporaryAWSCredentialsProvider

HadoopS3AccessHelper - Class in org.apache.flink.fs.s3hadoop

An implementation of the S3AccessHelper for the Hadoop S3A filesystem.

HadoopS3AccessHelper(S3AFileSystem, Configuration) - Constructor for class org.apache.flink.fs.s3hadoop.HadoopS3AccessHelper

J

java.xml.bind - module java.xml.bind

N

NAME - Static variable in class org.apache.flink.fs.s3.common.token.HadoopDynamicTemporaryAWSCredentialsProvider

Spelled out as a string literal (a compile-time constant) so that referencing NAME never triggers loading this class outside the flink-s3-fs-hadoop plugin.

O

org.apache.flink.fs.s3.common.token - package org.apache.flink.fs.s3.common.token

org.apache.flink.fs.s3hadoop - package org.apache.flink.fs.s3hadoop

org.apache.flink.fs.s3hadoop.token - package org.apache.flink.fs.s3hadoop.token

P

putObject(String, File) - Method in class org.apache.flink.fs.s3hadoop.HadoopS3AccessHelper

R

resolveCredentials() - Method in class org.apache.flink.fs.s3.common.token.HadoopDynamicTemporaryAWSCredentialsProvider

S

S3AFileSystemFactory - Class in org.apache.flink.fs.s3hadoop

Simple factory for the S3 file system, registered for the s3a:// scheme.

S3AFileSystemFactory() - Constructor for class org.apache.flink.fs.s3hadoop.S3AFileSystemFactory

S3FileSystemFactory - Class in org.apache.flink.fs.s3hadoop

Simple factory for the S3 file system.

S3FileSystemFactory() - Constructor for class org.apache.flink.fs.s3hadoop.S3FileSystemFactory

S3HadoopDelegationTokenProvider - Class in org.apache.flink.fs.s3hadoop.token

Delegation token provider for S3 Hadoop filesystems, based on AWS SDK v2.

S3HadoopDelegationTokenProvider() - Constructor for class org.apache.flink.fs.s3hadoop.token.S3HadoopDelegationTokenProvider

S3HadoopDelegationTokenReceiver - Class in org.apache.flink.fs.s3hadoop.token

Delegation token receiver for S3 Hadoop filesystems.

S3HadoopDelegationTokenReceiver() - Constructor for class org.apache.flink.fs.s3hadoop.token.S3HadoopDelegationTokenReceiver

serviceName() - Method in class org.apache.flink.fs.s3hadoop.token.S3HadoopDelegationTokenProvider

serviceName() - Method in class org.apache.flink.fs.s3hadoop.token.S3HadoopDelegationTokenReceiver

startMultiPartUpload(String) - Method in class org.apache.flink.fs.s3hadoop.HadoopS3AccessHelper

U

updateDelegationTokenConfig(Configuration) - Method in class org.apache.flink.fs.s3hadoop.S3FileSystemFactory

uploadPart(String, String, int, File, long) - Method in class org.apache.flink.fs.s3hadoop.HadoopS3AccessHelper

A C D G H J N O P R S U
All Classes All Packages