org.apache.iceberg.aws.s3

Class S3InputFile

java.lang.Object

org.apache.iceberg.aws.s3.S3InputFile

All Implemented Interfaces:

InputFile

public class S3InputFile
extends java.lang.Object
implements InputFile

Constructor Summary

Constructors

Constructor and Description
S3InputFile(software.amazon.awssdk.services.s3.S3Client client, org.apache.iceberg.aws.s3.S3URI uri)
S3InputFile(software.amazon.awssdk.services.s3.S3Client client, org.apache.iceberg.aws.s3.S3URI uri, AwsProperties awsProperties)

Method Summary

Modifier and Type	Method and Description
AwsProperties	awsProperties()
boolean	exists() Note: this may be stale if file was deleted since metadata is cached for size/existence checks.
long	getLength() Note: this may be stale if file was deleted since metadata is cached for size/existence checks.
protected software.amazon.awssdk.services.s3.model.HeadObjectResponse	getObjectMetadata()
java.lang.String	location()
SeekableInputStream	newStream() Opens a new SeekableInputStream for the underlying data file
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.io.InputFile

exists, location

Constructor Detail

S3InputFile

public S3InputFile(software.amazon.awssdk.services.s3.S3Client client,
                   org.apache.iceberg.aws.s3.S3URI uri)

S3InputFile

public S3InputFile(software.amazon.awssdk.services.s3.S3Client client,
                   org.apache.iceberg.aws.s3.S3URI uri,
                   AwsProperties awsProperties)

Method Detail

getLength

public long getLength()

Note: this may be stale if file was deleted since metadata is cached for size/existence checks.

Specified by:

getLength in interface InputFile

Returns:

content length

newStream

public SeekableInputStream newStream()

Description copied from interface: InputFile

Opens a new SeekableInputStream for the underlying data file

Specified by:

newStream in interface InputFile

Returns:

a seekable stream for reading the file

location

public java.lang.String location()

awsProperties

public AwsProperties awsProperties()

exists

public boolean exists()

Note: this may be stale if file was deleted since metadata is cached for size/existence checks.

Returns:

flag

getObjectMetadata

protected software.amazon.awssdk.services.s3.model.HeadObjectResponse getObjectMetadata()
                                                                                 throws software.amazon.awssdk.services.s3.model.S3Exception

Throws:

software.amazon.awssdk.services.s3.model.S3Exception

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object