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

Reply via email to