public ClickHousePipedOutputStream createPipedOutputStream(int bufferSize, int queueSize, int timeout,
            ClickHouseWriter writer) {
        return new BlockingPipedOutputStream(ClickHouseDataConfig.getBufferSize(bufferSize), queueSize, timeout,
                writer);
    }
Creates a piped output stream.

@param config non-null configuration
@param writer non-null custom writer
@return piped output stream
clickhouse-data/src/main/java/com/clickhouse/data/ClickHouseDataStreamFactory.java