Repository: tajo Updated Branches: refs/heads/branch-0.11.1 f2e4773f3 -> 8cdd21f7b
TAJO-2010: Parquet can not read null value. (fix method signature) Project: http://git-wip-us.apache.org/repos/asf/tajo/repo Commit: http://git-wip-us.apache.org/repos/asf/tajo/commit/8cdd21f7 Tree: http://git-wip-us.apache.org/repos/asf/tajo/tree/8cdd21f7 Diff: http://git-wip-us.apache.org/repos/asf/tajo/diff/8cdd21f7 Branch: refs/heads/branch-0.11.1 Commit: 8cdd21f7bb712a56fbe0e33a24dd4ba13980c701 Parents: f2e4773 Author: Jinho Kim <[email protected]> Authored: Fri Dec 4 12:04:54 2015 +0900 Committer: Jinho Kim <[email protected]> Committed: Fri Dec 4 12:04:54 2015 +0900 ---------------------------------------------------------------------- .../test/java/org/apache/tajo/storage/TestStorages.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tajo/blob/8cdd21f7/tajo-storage/tajo-storage-hdfs/src/test/java/org/apache/tajo/storage/TestStorages.java ---------------------------------------------------------------------- diff --git a/tajo-storage/tajo-storage-hdfs/src/test/java/org/apache/tajo/storage/TestStorages.java b/tajo-storage/tajo-storage-hdfs/src/test/java/org/apache/tajo/storage/TestStorages.java index 15fc5f7..c97923d 100644 --- a/tajo-storage/tajo-storage-hdfs/src/test/java/org/apache/tajo/storage/TestStorages.java +++ b/tajo-storage/tajo-storage-hdfs/src/test/java/org/apache/tajo/storage/TestStorages.java @@ -565,13 +565,13 @@ public class TestStorages { KeyValueSet options = new KeyValueSet(); TableMeta meta = CatalogUtil.newTableMeta(dataFormat, options); - meta.setPropertySet(CatalogUtil.newDefaultProperty(dataFormat)); - meta.putProperty(StorageConstants.TEXT_NULL, "\\\\N"); - meta.putProperty(StorageConstants.RCFILE_NULL, "\\\\N"); - meta.putProperty(StorageConstants.RCFILE_SERDE, TextSerializerDeserializer.class.getName()); - meta.putProperty(StorageConstants.SEQUENCEFILE_NULL, "\\"); + meta.setOptions(CatalogUtil.newDefaultProperty(dataFormat)); + meta.putOption(StorageConstants.TEXT_NULL, "\\\\N"); + meta.putOption(StorageConstants.RCFILE_NULL, "\\\\N"); + meta.putOption(StorageConstants.RCFILE_SERDE, TextSerializerDeserializer.class.getName()); + meta.putOption(StorageConstants.SEQUENCEFILE_NULL, "\\"); if (dataFormat.equalsIgnoreCase("AVRO")) { - meta.putProperty(StorageConstants.AVRO_SCHEMA_LITERAL, TEST_NULL_HANDLING_TYPES_AVRO_SCHEMA); + meta.putOption(StorageConstants.AVRO_SCHEMA_LITERAL, TEST_NULL_HANDLING_TYPES_AVRO_SCHEMA); } Path tablePath = new Path(testDir, "testProjectedNullHandlingTypes.data");
