Trait TryToStreamPb

pub trait TryToStreamPb {
    // Provided method
    fn try_to_stream_prost_body(
        &self,
        _state: &mut BuildFragmentGraphState,
    ) -> Result<NodeBody, SchedulerError> { ... }
}

Provided Methods

fn try_to_stream_prost_body( &self, _state: &mut BuildFragmentGraphState, ) -> Result<NodeBody, SchedulerError>

Implementors

impl TryToStreamPb for BatchDelete

impl TryToStreamPb for BatchExchange

impl TryToStreamPb for BatchExpand

impl TryToStreamPb for BatchFileScan

impl TryToStreamPb for BatchFilter

impl TryToStreamPb for BatchGroupTopN

impl TryToStreamPb for BatchHashAgg

impl TryToStreamPb for BatchHashJoin

impl TryToStreamPb for BatchHopWindow

impl TryToStreamPb for BatchIcebergScan

impl TryToStreamPb for BatchInsert

impl TryToStreamPb for BatchKafkaScan

impl TryToStreamPb for BatchLimit

impl TryToStreamPb for BatchLogSeqScan

impl TryToStreamPb for BatchLookupJoin

impl TryToStreamPb for BatchMaxOneRow

impl TryToStreamPb for BatchMySqlQuery

impl TryToStreamPb for BatchNestedLoopJoin

impl TryToStreamPb for BatchOverWindow

impl TryToStreamPb for BatchPostgresQuery

impl TryToStreamPb for BatchProject

impl TryToStreamPb for BatchProjectSet

impl TryToStreamPb for BatchSeqScan

impl TryToStreamPb for BatchSimpleAgg

impl TryToStreamPb for BatchSort

impl TryToStreamPb for BatchSortAgg

impl TryToStreamPb for BatchSource

impl TryToStreamPb for BatchSysSeqScan

impl TryToStreamPb for BatchTableFunction

impl TryToStreamPb for BatchTopN

impl TryToStreamPb for BatchUnion

impl TryToStreamPb for BatchUpdate

impl TryToStreamPb for BatchValues

impl TryToStreamPb for LogicalAgg

impl TryToStreamPb for LogicalApply

impl TryToStreamPb for LogicalCdcScan

impl TryToStreamPb for LogicalChangeLog

impl TryToStreamPb for LogicalCteRef

impl TryToStreamPb for LogicalDedup

impl TryToStreamPb for LogicalDelete

impl TryToStreamPb for LogicalExcept

impl TryToStreamPb for LogicalExpand

impl TryToStreamPb for LogicalFileScan

impl TryToStreamPb for LogicalFilter

impl TryToStreamPb for LogicalHopWindow

impl TryToStreamPb for LogicalIcebergScan

impl TryToStreamPb for LogicalInsert

impl TryToStreamPb for LogicalIntersect

impl TryToStreamPb for LogicalJoin

impl TryToStreamPb for LogicalKafkaScan

impl TryToStreamPb for LogicalLimit

impl TryToStreamPb for LogicalMaxOneRow

impl TryToStreamPb for LogicalMultiJoin

impl TryToStreamPb for LogicalMySqlQuery

impl TryToStreamPb for LogicalNow

impl TryToStreamPb for LogicalOverWindow

impl TryToStreamPb for LogicalPostgresQuery

impl TryToStreamPb for LogicalProject

impl TryToStreamPb for LogicalProjectSet

impl TryToStreamPb for LogicalRecursiveUnion

impl TryToStreamPb for LogicalScan

impl TryToStreamPb for LogicalShare

impl TryToStreamPb for LogicalSource

impl TryToStreamPb for LogicalSysScan

impl TryToStreamPb for LogicalTableFunction

impl TryToStreamPb for LogicalTopN

impl TryToStreamPb for LogicalUnion

impl TryToStreamPb for LogicalUpdate

impl TryToStreamPb for LogicalValues

impl TryToStreamPb for StreamDeltaJoin

impl TryToStreamPb for StreamTemporalJoin

impl<T: StreamNode> TryToStreamPb for T