commit 14a86402ea9daa9471898711f9b3a8aab5412fac Author: Owen O'Malley Date: Thu Jun 25 12:44:08 2015 -0700 HIVE-11115. Remvoe dependence from WriterImpl to OrcInputFormat. diff --git ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java index 0053a19..8800003 100644 --- ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/orc/WriterImpl.java @@ -76,6 +76,8 @@ 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; @@ -102,6 +104,7 @@ 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; @@ -2461,7 +2464,7 @@ public synchronized long writeIntermediateFooter() throws IOException { int footLength = writeFooter(rawWriter.getPos() - metaLength); rawWriter.writeByte(writePostScript(footLength, metaLength)); stripesAtLastFlush = stripes.size(); - OrcInputFormat.SHIMS.hflush(rawWriter); + SHIMS.hflush(rawWriter); } return rawWriter.getPos(); }