pub struct HashShuffle { /* private fields */ }Expand description
Hash-based shuffle implementation.
Implementations§
Source§impl HashShuffle
impl HashShuffle
Sourcepub fn new(column_name: String, num_partitions: usize) -> Result<Self>
pub fn new(column_name: String, num_partitions: usize) -> Result<Self>
Create a new hash shuffle.
Sourcepub fn shuffle(
&self,
batch: &RecordBatch,
) -> Result<HashMap<PartitionId, RecordBatch>>
pub fn shuffle( &self, batch: &RecordBatch, ) -> Result<HashMap<PartitionId, RecordBatch>>
Shuffle a record batch.
Auto Trait Implementations§
impl Freeze for HashShuffle
impl RefUnwindSafe for HashShuffle
impl Send for HashShuffle
impl Sync for HashShuffle
impl Unpin for HashShuffle
impl UnsafeUnpin for HashShuffle
impl UnwindSafe for HashShuffle
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request