Package-level declarations
Types
Link copied to clipboard
class FilePartAccumulatorFactory(pathFactory: ObjectStoragePathFactory, outputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, loadStrategy: ObjectLoader)
Link copied to clipboard
class FilePartAccumulatorLegacy(pathFactory: ObjectStoragePathFactory, stream: DestinationStream, outputQueue: PartitionedQueue<PipelineEvent<ObjectKey, ObjectLoaderPartFormatter.FormattedPart>>, loadStrategy: ObjectLoader)
Link copied to clipboard
ObjectLoader is for the use case where a destination writes records into some number of files in a file system or cloud storage provider whose client supports multipart uploads.
Link copied to clipboard
class ObjectStorageStreamLoader<T : RemoteObject<*>>(val stream: DestinationStream, client: ObjectStorageClient<T>, destinationStateManager: DestinationStateManager<ObjectStorageDestinationState>) : StreamLoader
Link copied to clipboard
@Singleton
@Secondary