From a314e56457d8f6949b7d7463882e98127c24b680 Mon Sep 17 00:00:00 2001 From: hyukjinkwon Date: Wed, 29 Jun 2016 12:54:30 +0900 Subject: [PATCH] Clean up orc compression option as well --- python/pyspark/sql/readwriter.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/python/pyspark/sql/readwriter.py b/python/pyspark/sql/readwriter.py index 3f28d7ad5051..5f34a662a055 100644 --- a/python/pyspark/sql/readwriter.py +++ b/python/pyspark/sql/readwriter.py @@ -693,8 +693,7 @@ def orc(self, path, mode=None, partitionBy=None, compression=None): self.mode(mode) if partitionBy is not None: self.partitionBy(partitionBy) - if compression is not None: - self.option("compression", compression) + self._set_opts(compression=compression) self._jwrite.orc(path) @since(1.4)