create_stream_for_sink
stream = create_stream_for_sink(aconnector, mode, NULL);
new_stream = create_stream_for_sink(aconnector,