private void processStreamingAPI(String dbName, String tblName)
      throws StreamingException {
      List<CompactorTestUtil.StreamingConnectionOption> options = Lists
          .newArrayList(new CompactorTestUtil.StreamingConnectionOption(false, false),
              new CompactorTestUtil.StreamingConnectionOption(false, false),
              new CompactorTestUtil.StreamingConnectionOption(true, false));
      CompactorTestUtil.runStreamingAPI(conf, dbName, tblName, options);
  }
Tests compaction of tables that were populated by LOAD DATA INPATH statements.

In this scenario original ORC files are a structured in the following way:
comp3
|--delta_0000001_0000001_0000
   |--000000_0
|--delta_0000002_0000002_0000
   |--000000_0
   |--000001_0

..where comp3 table is not bucketed.

@throws Exception
itests/hive-unit/src/test/java/org/apache/hadoop/hive/ql/txn/compactor/TestCompactor.java