Hi Team, Is there a way to enable compression in StreamingFileSink API for Row-encoded formats ?.
val sink: StreamingFileSink[String] = StreamingFileSink .forRowFormat(new Path(outputPath), new SimpleStringEncoder[String]("UTF-8")) Regards, Vijay
Hi Team, Is there a way to enable compression in StreamingFileSink API for Row-encoded formats ?.
val sink: StreamingFileSink[String] = StreamingFileSink .forRowFormat(new Path(outputPath), new SimpleStringEncoder[String]("UTF-8")) Regards, Vijay