You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2015/07/08 03:57:19 UTC
[26/31] hive git commit: HIVE-11115. Remvoe dependence from
WriterImpl to OrcInputFormat.
HIVE-11115. Remvoe dependence from WriterImpl to OrcInputFormat.
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/f7905915
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/f7905915
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/f7905915
Branch: refs/heads/llap
Commit: f790591590478701699b34c46ce83c23bd065361
Parents: ac9adfd
Author: Owen O'Malley <om...@apache.org>
Authored: Thu Jun 25 12:44:08 2015 -0700
Committer: Owen O'Malley <om...@apache.org>
Committed: Tue Jul 7 13:47:32 2015 -0700
----------------------------------------------------------------------
ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/f7905915/ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java
index 61a90dd..ee6110e 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java
@@ -76,6 +76,8 @@ import org.apache.hadoop.hive.serde2.objectinspector.primitive.TimestampObjectIn
import org.apache.hadoop.hive.serde2.typeinfo.CharTypeInfo;
import org.apache.hadoop.hive.serde2.typeinfo.DecimalTypeInfo;
import org.apache.hadoop.hive.serde2.typeinfo.VarcharTypeInfo;
+import org.apache.hadoop.hive.shims.HadoopShims;
+import org.apache.hadoop.hive.shims.ShimLoader;
import org.apache.hadoop.io.BytesWritable;
import org.apache.hadoop.io.Text;
@@ -107,6 +109,7 @@ import com.google.protobuf.CodedOutputStream;
public class WriterImpl implements Writer, MemoryManager.Callback {
private static final Log LOG = LogFactory.getLog(WriterImpl.class);
+ static final HadoopShims SHIMS = ShimLoader.getHadoopShims();
private static final int HDFS_BUFFER_SIZE = 256 * 1024;
private static final int MIN_ROW_INDEX_STRIDE = 1000;
@@ -2477,7 +2480,7 @@ public class WriterImpl implements Writer, MemoryManager.Callback {
int footLength = writeFooter(rawWriter.getPos() - metaLength);
rawWriter.writeByte(writePostScript(footLength, metaLength));
stripesAtLastFlush = stripes.size();
- OrcInputFormat.SHIMS.hflush(rawWriter);
+ SHIMS.hflush(rawWriter);
}
return rawWriter.getPos();
}