Package org.gridgain.internal.sql.copy.s3

Class S3ClientFactory

java.lang.Object

org.gridgain.internal.sql.copy.s3.S3ClientFactory

public class S3ClientFactory
extends Object

S3 client factory.

Constructor Summary

Constructors

Constructor	Description
S3ClientFactory()

Method Summary

Modifier and Type	Method	Description
static software.amazon.awssdk.services.s3.S3Client	createS3Client(Map<String,String> properties, LocationGuard guard)	Creates S3 client.
static Reader	getInputStreamReader(String path, Map<String,String> properties, LocationGuard guard)	Creates Input Reader for reading an S3 key.
static Writer	getOutputStreamWriter(String path, Map<String,String> properties, LocationGuard guard)	Creates Output Writer for writing an S3 key.
static boolean	keyExist(software.amazon.awssdk.services.s3.S3Client client, S3Uri uri)	Checks if file exists.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

S3ClientFactory

public S3ClientFactory()

Method Details

getInputStreamReader

public static Reader getInputStreamReader(String path,
 Map<String,String> properties,
 LocationGuard guard)

Creates Input Reader for reading an S3 key.

Parameters:

path - S3 URI.

properties - S3 properties.

getOutputStreamWriter

public static Writer getOutputStreamWriter(String path,
 Map<String,String> properties,
 LocationGuard guard)
                                    throws IOException

Creates Output Writer for writing an S3 key.

Parameters:

path - S3 URI.

properties - S3 properties.

Throws:

IOException

createS3Client

public static software.amazon.awssdk.services.s3.S3Client createS3Client(Map<String,String> properties,
 LocationGuard guard)

Creates S3 client.

keyExist

public static boolean keyExist(software.amazon.awssdk.services.s3.S3Client client,
 S3Uri uri)

Checks if file exists.