Struct SortSpec 

pub struct SortSpec { /* private fields */ }

A sort operation.

There is no user job: the cluster does the sorting. Its result is a sorted table, which is what ReduceSpec needs.

use ytsaurus_client::SortSpec;

let spec = SortSpec::new(["//tmp/unsorted"], "//tmp/sorted", ["word"]);

Implementations

impl SortSpec

pub fn new<I, K>(inputs: I, output: impl Into<String>, sort_by: K) -> Self

where I: IntoIterator, I::Item: Into<String>, K: IntoIterator, K::Item: Into<String>,

Sorts inputs into output, ordered by sort_by.

Note the single output: sort writes one table, however many it reads.

pub fn with_raw(self, key: impl Into<String>, value: YsonValue) -> Self

Sets any spec field this builder does not model — partition_count, data_size_per_partition_job and the rest of the sort tuning knobs.

pub fn to_yson(&self) -> YsonValue

Renders the spec.

Trait Implementations

impl Clone for SortSpec

fn clone(&self) -> SortSpec

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SortSpec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.