Class | Description |
---|---|
RangeShuffle |
RangeShuffle Util to shuffle the input stream by the sampling range.
|
RangeShuffle.KeyAndSizeExtractor<T> |
KeyAndSizeExtractor is responsible for extracting the sort key and row size.
|
RangeShuffle.LocalSampleOperator<T> |
LocalSampleOperator wraps the sample logic on the partition side (the first phase of
distributed sample algorithm).
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.