pub fn build_upstream_sink_info(
sink: &PbSink,
sink_fragment_id: FragmentId,
target_table: &PbTable,
target_fragment_id: FragmentId,
) -> MetaResult<UpstreamSinkInfo>
pub fn build_upstream_sink_info(
sink: &PbSink,
sink_fragment_id: FragmentId,
target_table: &PbTable,
target_fragment_id: FragmentId,
) -> MetaResult<UpstreamSinkInfo>