ObjectLoaderFormattedPartPartitioner
class ObjectLoaderFormattedPartPartitioner<K : WithStream, T> : OutputPartitioner<K, T, ObjectKey, ObjectLoaderPartFormatter.FormattedPart> (source)
Distribute the parts randomly across loaders. (Testing shows this is the most efficient pattern.)
Functions
Link copied to clipboard
open override fun getOutputKey(inputKey: K, output: ObjectLoaderPartFormatter.FormattedPart): ObjectKey