Package org.apache.iceberg.aws.s3
Class S3InputFile
- java.lang.Object
-
- org.apache.iceberg.aws.s3.S3InputFile
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description AwsProperties
awsProperties()
boolean
exists()
Note: this may be stale if file was deleted since metadata is cached for size/existence checks.static S3InputFile
fromLocation(java.lang.String location, software.amazon.awssdk.services.s3.S3Client client)
static S3InputFile
fromLocation(java.lang.String location, software.amazon.awssdk.services.s3.S3Client client, AwsProperties awsProperties)
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 newSeekableInputStream
for the underlying data filejava.lang.String
toString()
-
-
-
Method Detail
-
fromLocation
public static S3InputFile fromLocation(java.lang.String location, software.amazon.awssdk.services.s3.S3Client client)
-
fromLocation
public static S3InputFile fromLocation(java.lang.String location, software.amazon.awssdk.services.s3.S3Client client, AwsProperties awsProperties)
-
getLength
public long getLength()
Note: this may be stale if file was deleted since metadata is cached for size/existence checks.
-
newStream
public SeekableInputStream newStream()
Description copied from interface:InputFile
Opens a newSeekableInputStream
for the underlying data 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 classjava.lang.Object
-
-