From d9f59cf18afadb81b18c0d270948d82721d16cfb Mon Sep 17 00:00:00 2001
From: Kristian Kaufmann <kristianwkaufmann@gmail.com>
Date: Fri, 12 Jun 2015 16:20:09 -0400
Subject: Adds autoFlush setting to HbaseSource.

The setting defaults to true to reproduce current behavior
---
 src/main/java/parallelai/spyglass/hbase/HBaseRecordWriter.java | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'src/main/java/parallelai/spyglass/hbase/HBaseRecordWriter.java')

diff --git a/src/main/java/parallelai/spyglass/hbase/HBaseRecordWriter.java b/src/main/java/parallelai/spyglass/hbase/HBaseRecordWriter.java
index 50aa116..24654f5 100644
--- a/src/main/java/parallelai/spyglass/hbase/HBaseRecordWriter.java
+++ b/src/main/java/parallelai/spyglass/hbase/HBaseRecordWriter.java
@@ -30,6 +30,9 @@ public class HBaseRecordWriter
 
   public void close(Reporter reporter)
     throws IOException {
+    if (!m_table.isAutoFlush()) {
+        m_table.flushCommits();
+    }
     m_table.close();
   }
 
-- 
cgit v1.2.3