pipe is assumed to have the schema above, otherwise an error may occur The exact same pipe is returned to match the legacy Source API.
pipe is assumed to have the schema above, otherwise an error may occur The exact same pipe is returned to match the legacy Source API.
Transform this sink into another type by applying a function first
Transform this sink into another type by applying a function first