jffwang
/
hetu-core
0
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Codex issue fix

This commit is contained in:
rajeevrastogi 2020-09-07 13:18:49 +05:30
parent aab1ba8a8e
commit 55fd37831c
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
presto-orc/src/main/java/io/prestosql/orc/AbstractOrcRecordReader.java
View File

@ -325,7 +325,7 @@ abstract class AbstractOrcRecordReader<T extends AbstractColumnReader>
if (!andDomainMap.isEmpty()) {
Iterator<Integer> thisStripeMatchingRows = ((andDomainMap.entrySet().iterator().next()).getKey()).getMatches(andDomainMap);
if (thisStripeMatchingRows.hasNext()) {
if (thisStripeMatchingRows != null && thisStripeMatchingRows.hasNext()) {
PeekingIterator<Integer> peekingIterator = Iterators.peekingIterator(thisStripeMatchingRows);
if (peekingIterator.peek() != null) {
this.stripeMatchingRows.put(stripe, peekingIterator);
@ -337,7 +337,7 @@ abstract class AbstractOrcRecordReader<T extends AbstractColumnReader>
if (!orDomainMap.isEmpty()) {
for (Map.Entry<Index, Domain> indexDomainEntry : orDomainMap.entrySet()) {
Iterator<Integer> thisStripeMatchingRows = (indexDomainEntry.getKey()).getMatches(indexDomainEntry.getValue());
if (thisStripeMatchingRows.hasNext()) {
if (thisStripeMatchingRows != null && thisStripeMatchingRows.hasNext()) {
/* any one matched; then include the stripe */
return false;
}

6
presto-orc/src/main/java/io/prestosql/orc/reader/AbstractLongSelectiveColumnReader.java
View File

@ -163,7 +163,7 @@ abstract class AbstractLongSelectiveColumnReader<T>
}
valuesCopy[positionIndex] = this.values[i];
if (includeNulls) {
if (nullsCopy != null) {
nullsCopy[positionIndex] = this.nulls[i];
}
@ -204,7 +204,7 @@ abstract class AbstractLongSelectiveColumnReader<T>
}
valuesCopy[positionIndex] = toIntExact(this.values[i]);
if (includeNulls) {
if (nullsCopy != null) {
nullsCopy[positionIndex] = this.nulls[i];
}
@ -235,7 +235,7 @@ abstract class AbstractLongSelectiveColumnReader<T>
}
valuesCopy[positionIndex] = (short) this.values[i];
if (includeNulls) {
if (nullsCopy != null) {
nullsCopy[positionIndex] = this.nulls[i];
}