Implementing Basic DataStreamAPI Sink - Support Raw stream of data (Forward to ClickHouse with different formats) - Support POJO - Support for Scala wrapping