package s3
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- case class S3FileStaging(uploadId: String, uploadPartTag: String, destinationKey: String) extends Product with Serializable
- class S3FileStorage[P] extends TwoPhaseCommitBatchStorage[PartitionedFileRecordBatch[P, FileRecordBatch], S3MultiFileStaging] with Logging
An S3 compatible file storage, stores files and commits offsets to Kafka in a two-phase transaction.
An S3 compatible file storage, stores files and commits offsets to Kafka in a two-phase transaction. The file upload prepare/stage phases consist of starting and completing a multi-part upload with a single part.
- case class S3MultiFileStaging(fileUploads: Seq[S3FileStaging]) extends Product with Serializable
Value Members
- object S3FileStorage
- object S3MultiFileStaging extends Serializable