You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tajo.apache.org by jh...@apache.org on 2015/12/04 04:06:02 UTC
tajo git commit: TAJO-2010: Parquet can not read null value. (fix
method signature)
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 <jh...@apache.org>
Authored: Fri Dec 4 12:04:54 2015 +0900
Committer: Jinho Kim <jh...@apache.org>
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");