abstract class S3InputFormat[K, V] extends InputFormat[K, V]

Reads keys from s3n URL using AWS Java SDK. The number of keys per InputSplits are controlled by S3 pagination. If AWS credentials are not part of the URL they will be discovered using [DefaultAWSCredentialsProviderChain]:

  • EnvironmentVariableCredentialsProvider
  • SystemPropertiesCredentialsProvider
  • ProfileCredentialsProvider
  • InstanceProfileCredentialsProvider
Linear Supertypes
InputFormat[K, V], AnyRef, Any
Known Subclasses
BytesS3InputFormat, TiffTagsS3InputFormat, GeoTiffS3InputFormat, MultibandGeoTiffS3InputFormat, TemporalGeoTiffS3InputFormat, TemporalMultibandGeoTiffS3InputFormat
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. S3InputFormat
  2. InputFormat
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new S3InputFormat()

Abstract Value Members

  1. abstract def createRecordReader(arg0: InputSplit, arg1: TaskAttemptContext): RecordReader[K, V]
    Definition Classes
    InputFormat
    Annotations
    @throws( classOf[java.io.IOException] ) @throws( ... )

Concrete Value Members

  1. def getS3Client(context: JobContext): S3Client
  2. def getSplits(context: JobContext): List[InputSplit]
    Definition Classes
    S3InputFormat → InputFormat