This is an automated email from the ASF dual-hosted git repository.
mhubail pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git
The following commit(s) were added to refs/heads/master by this push:
new 00c72fc [NO ISSUE][MTD] Fix Reading Dataset Compression From Dataset
Record
00c72fc is described below
commit 00c72fcda54568ab6d9a26ffd8b33b1e70a68cc8
Author: Murtadha Hubail <[email protected]>
AuthorDate: Sun Jun 16 03:07:50 2019 +0300
[NO ISSUE][MTD] Fix Reading Dataset Compression From Dataset Record
- user model changes: no
- storage format changes: no
- interface changes: no
Details:
- Fix reading the dataset compression scheme by reading its
value from the compression record rather than the dataset record.
Change-Id: I3bdb1f64143fed43dc9eb37cf8a2fadbfd37dfde
Reviewed-on: https://asterix-gerrit.ics.uci.edu/3445
Contrib: Jenkins <[email protected]>
Tested-by: Jenkins <[email protected]>
Integration-Tests: Jenkins <[email protected]>
Reviewed-by: Murtadha Hubail <[email protected]>
Reviewed-by: Wail Alkowaileet <[email protected]>
---
.../metadata/entitytupletranslators/DatasetTupleTranslator.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatasetTupleTranslator.java
b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatasetTupleTranslator.java
index 27978ab..7f8b9bf 100644
---
a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatasetTupleTranslator.java
+++
b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entitytupletranslators/DatasetTupleTranslator.java
@@ -282,7 +282,8 @@ public class DatasetTupleTranslator extends
AbstractTupleTranslator<Dataset> {
final ARecordType compressionType = (ARecordType)
datasetType.getFieldTypes()[compressionIndex];
final int schemeIndex = compressionType
.getFieldIndex(MetadataRecordTypes.DATASET_ARECORD_DATASET_COMPRESSION_SCHEME_FIELD_NAME);
- return ((AString)
datasetRecord.getValueByPos(schemeIndex)).getStringValue();
+ final ARecord compressionRecord = (ARecord)
datasetRecord.getValueByPos(compressionIndex);
+ return ((AString)
compressionRecord.getValueByPos(schemeIndex)).getStringValue();
}
return CompressionManager.NONE;
}
