Skip to main content

build_sink

kinetic::topology::build_impl

Function build_sink 

Source 
pub fn build_sink(
    config: &SinkConfigEnum,
    cx: SinkContext,
) -> Result<JoinHandle<()>>