pub struct ShuffleConfig {
pub shuffle_type: ShuffleType,
pub key: ShuffleKey,
pub num_partitions: usize,
pub buffer_size: usize,
}Expand description
Configuration for shuffle operations.
Fields§
§shuffle_type: ShuffleTypeType of shuffle.
key: ShuffleKeyKey to shuffle by.
num_partitions: usizeNumber of target partitions.
buffer_size: usizeBuffer size for shuffle writes.
Implementations§
Source§impl ShuffleConfig
impl ShuffleConfig
Sourcepub fn new(
shuffle_type: ShuffleType,
key: ShuffleKey,
num_partitions: usize,
) -> Result<Self>
pub fn new( shuffle_type: ShuffleType, key: ShuffleKey, num_partitions: usize, ) -> Result<Self>
Create a new shuffle configuration.
Sourcepub fn with_buffer_size(self, size: usize) -> Self
pub fn with_buffer_size(self, size: usize) -> Self
Set the buffer size.
Trait Implementations§
Source§impl Clone for ShuffleConfig
impl Clone for ShuffleConfig
Source§fn clone(&self) -> ShuffleConfig
fn clone(&self) -> ShuffleConfig
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for ShuffleConfig
impl RefUnwindSafe for ShuffleConfig
impl Send for ShuffleConfig
impl Sync for ShuffleConfig
impl Unpin for ShuffleConfig
impl UnsafeUnpin for ShuffleConfig
impl UnwindSafe for ShuffleConfig
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> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
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