Github user gvramana commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2313#discussion_r188845326
--- Diff:
core/src/main/java/org/apache/carbondata/core/datastore/compression/SnappyCompressor.java
---
@@ -135,52 +136,52 @@ public String getName() {
return Snappy.uncompressIntArray(compInput);
} catch (IOException e) {
LOGGER.error(e, e.getMessage());
+ throw new RuntimeException(e);
}
- return null;
}
@Override public int[] unCompressInt(byte[] compInput, int offset, int
length) {
try {
return Snappy.uncompressIntArray(compInput, offset, length);
} catch (IOException e) {
LOGGER.error(e, e.getMessage());
+ throw new RuntimeException(e);
}
- return null;
}
@Override public byte[] compressLong(long[] unCompInput) {
try {
return Snappy.compress(unCompInput);
} catch (IOException e) {
LOGGER.error(e, e.getMessage());
- return null;
+ throw new RuntimeException(e);
}
}
- @Override public long[] unCompressLong(byte[] compInput) {
+ @Override public long[] uncompresslong(byte[] compinput) {
--- End diff --
why is it renamed?
---
