flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hshreedha...@apache.org
Subject [4/4] flume git commit: FLUME-1734. Add a Hive Sink based on Hive Streaming support.
Date Tue, 10 Feb 2015 07:16:59 GMT
FLUME-1734. Add a Hive Sink based on Hive Streaming support.

(Roshan Naik via Hari Shreedharan)


Project: http://git-wip-us.apache.org/repos/asf/flume/repo
Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/5dfd3d96
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/5dfd3d96
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/5dfd3d96

Branch: refs/heads/flume-1.6
Commit: 5dfd3d963762b23add165a9034c5ef93493d2bc7
Parents: d47ee46
Author: Hari Shreedharan <hshreedharan@apache.org>
Authored: Mon Feb 9 23:15:02 2015 -0800
Committer: Hari Shreedharan <hshreedharan@apache.org>
Committed: Mon Feb 9 23:16:47 2015 -0800

----------------------------------------------------------------------
 bin/flume-ng                                    |  12 +
 conf/log4j.properties                           |   1 +
 .../flume/conf/sink/SinkConfiguration.java      |   9 +-
 .../org/apache/flume/conf/sink/SinkType.java    |   8 +-
 flume-ng-dist/pom.xml                           |   8 +
 flume-ng-doc/sphinx/FlumeUserGuide.rst          | 143 +++++
 .../handlers/thrift/ThriftFlumeEventServer.java |  18 +-
 .../thriftLegacy/TestThriftLegacySource.java    |   1 -
 .../flume/thrift/ThriftSourceProtocol.java      |  18 +-
 .../flume-hive-sink/metastore_db/db.lck         | Bin 0 -> 38 bytes
 .../flume-hive-sink/metastore_db/dbex.lck       | Bin 0 -> 4 bytes
 .../flume-hive-sink/metastore_db/log/log.ctrl   | Bin 0 -> 48 bytes
 .../flume-hive-sink/metastore_db/log/log3.dat   | Bin 0 -> 1048591 bytes
 .../flume-hive-sink/metastore_db/log/log4.dat   | Bin 0 -> 1048576 bytes
 .../metastore_db/log/logmirror.ctrl             | Bin 0 -> 48 bytes
 .../flume-hive-sink/metastore_db/seg0/c10.dat   | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c101.dat  | Bin 0 -> 16384 bytes
 .../flume-hive-sink/metastore_db/seg0/c111.dat  | Bin 0 -> 20480 bytes
 .../flume-hive-sink/metastore_db/seg0/c121.dat  | Bin 0 -> 16384 bytes
 .../flume-hive-sink/metastore_db/seg0/c130.dat  | Bin 0 -> 12288 bytes
 .../flume-hive-sink/metastore_db/seg0/c141.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c150.dat  | Bin 0 -> 28672 bytes
 .../flume-hive-sink/metastore_db/seg0/c161.dat  | Bin 0 -> 20480 bytes
 .../flume-hive-sink/metastore_db/seg0/c171.dat  | Bin 0 -> 20480 bytes
 .../flume-hive-sink/metastore_db/seg0/c180.dat  | Bin 0 -> 69632 bytes
 .../flume-hive-sink/metastore_db/seg0/c191.dat  | Bin 0 -> 16384 bytes
 .../flume-hive-sink/metastore_db/seg0/c1a1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1b1.dat  | Bin 0 -> 16384 bytes
 .../flume-hive-sink/metastore_db/seg0/c1c0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1d1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1e0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1e90.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1ea1.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1eb0.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1ec1.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1ed0.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1ee0.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1ef0.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1f01.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1f1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1f11.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1f20.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1f30.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1f41.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c1f50.dat | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c20.dat   | Bin 0 -> 102400 bytes
 .../flume-hive-sink/metastore_db/seg0/c200.dat  | Bin 0 -> 16384 bytes
 .../flume-hive-sink/metastore_db/seg0/c211.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c221.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c230.dat  | Bin 0 -> 385024 bytes
 .../flume-hive-sink/metastore_db/seg0/c241.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c251.dat  | Bin 0 -> 20480 bytes
 .../flume-hive-sink/metastore_db/seg0/c260.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c271.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c281.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c290.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c2a1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c2b1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c2c1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c2d0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c2e1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c2f0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c300.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c31.dat   | Bin 0 -> 28672 bytes
 .../flume-hive-sink/metastore_db/seg0/c311.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c321.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c331.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c340.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c351.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c361.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c371.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c380.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c391.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c3a1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c3b1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c3c0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c3d1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c3e1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c3f1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c400.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c41.dat   | Bin 0 -> 69632 bytes
 .../flume-hive-sink/metastore_db/seg0/c411.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c421.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c430.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c441.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c451.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c461.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c51.dat   | Bin 0 -> 32768 bytes
 .../flume-hive-sink/metastore_db/seg0/c540.dat  | Bin 0 -> 131072 bytes
 .../flume-hive-sink/metastore_db/seg0/c551.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c560.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/c571.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c581.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c591.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c5a0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c5b1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c5c0.dat  | Bin 0 -> 12288 bytes
 .../flume-hive-sink/metastore_db/seg0/c5d1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c5e0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c5f1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c60.dat   | Bin 0 -> 16384 bytes
 .../flume-hive-sink/metastore_db/seg0/c600.dat  | Bin 0 -> 98304 bytes
 .../flume-hive-sink/metastore_db/seg0/c611.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c620.dat  | Bin 0 -> 98304 bytes
 .../flume-hive-sink/metastore_db/seg0/c631.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c640.dat  | Bin 0 -> 98304 bytes
 .../flume-hive-sink/metastore_db/seg0/c651.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c660.dat  | Bin 0 -> 12288 bytes
 .../flume-hive-sink/metastore_db/seg0/c671.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c680.dat  | Bin 0 -> 98304 bytes
 .../flume-hive-sink/metastore_db/seg0/c691.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c6a0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c6b1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c6c0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c6d1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c6e0.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/c6f1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c700.dat  | Bin 0 -> 98304 bytes
 .../flume-hive-sink/metastore_db/seg0/c71.dat   | Bin 0 -> 16384 bytes
 .../flume-hive-sink/metastore_db/seg0/c711.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c720.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/c731.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c740.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c751.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c760.dat  | Bin 0 -> 98304 bytes
 .../flume-hive-sink/metastore_db/seg0/c771.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c780.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c791.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c7a0.dat  | Bin 0 -> 98304 bytes
 .../flume-hive-sink/metastore_db/seg0/c7b1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c7c1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c7d1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c7e1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c7f1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c801.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c81.dat   | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c811.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c821.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c831.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c841.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c851.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c861.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c871.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c881.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c891.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c8a1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c8b1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c8c1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c8d1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c8e1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c8f0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c90.dat   | Bin 0 -> 86016 bytes
 .../flume-hive-sink/metastore_db/seg0/c901.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c910.dat  | Bin 0 -> 12288 bytes
 .../flume-hive-sink/metastore_db/seg0/c921.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c930.dat  | Bin 0 -> 98304 bytes
 .../flume-hive-sink/metastore_db/seg0/c941.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c950.dat  | Bin 0 -> 12288 bytes
 .../flume-hive-sink/metastore_db/seg0/c961.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c971.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c981.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c991.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/c9a1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c9b1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c9c1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c9d0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c9e1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/c9f0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/ca01.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/ca1.dat   | Bin 0 -> 98304 bytes
 .../flume-hive-sink/metastore_db/seg0/ca10.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/ca21.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/ca31.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/ca40.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/ca51.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/ca61.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/ca70.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/ca81.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/ca90.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/caa1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cab1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cac1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cad1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cae1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/caf1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cb00.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cb1.dat   | Bin 0 -> 16384 bytes
 .../flume-hive-sink/metastore_db/seg0/cb11.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cb21.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/cb31.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cb40.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cb51.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cb61.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cb71.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/cb80.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cb91.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cba1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cbb1.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/cbc0.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cbd1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cbe1.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/cbf1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cc0.dat   | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cc00.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/cc11.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cc20.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/cc31.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cc41.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cc51.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cc61.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cc70.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cc81.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cc91.dat  | Bin 0 -> 65536 bytes
 .../flume-hive-sink/metastore_db/seg0/cca1.dat  | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cd1.dat   | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/ce1.dat   | Bin 0 -> 8192 bytes
 .../flume-hive-sink/metastore_db/seg0/cf0.dat   | Bin 0 -> 24576 bytes
 .../flume-hive-sink/metastore_db/seg0/d18e0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d18f1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1900.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1911.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1920.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1930.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1940.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1951.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1961.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1970.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1980.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1991.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d19a0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d19b0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d19c1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d19d0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d19e1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d19f0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1a00.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1a10.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1a21.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1a31.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1a40.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1a50.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1a61.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1a70.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1a80.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1a91.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1aa0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1ab1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1ac0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1ad0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1ae0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1af1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1b01.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1b10.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1b20.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1b31.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1b40.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1b50.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1b61.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1b70.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1b81.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1b90.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1ba0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1bb0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1bc1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1bd1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1be0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1bf0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1c01.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1c10.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1c20.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1c31.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1c40.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1c51.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1c60.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1c70.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1c80.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1c91.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1ca1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1cb0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1cc0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1cd1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1ce0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1cf0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1d01.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1d10.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1d21.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1d30.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1d40.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1d50.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1d61.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1d71.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1d80.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1d90.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1da1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1db0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1dc0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1dd1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1de0.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1df1.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1e00.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1e10.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1e20.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1e31.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1e41.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1e50.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1e60.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1e71.dat | Bin 0 -> 4096 bytes
 .../flume-hive-sink/metastore_db/seg0/d1e80.dat | Bin 0 -> 4096 bytes
 .../metastore_db/service.properties             |  22 +
 flume-ng-sinks/flume-hive-sink/pom.xml          | 189 +++++++
 .../java/org/apache/flume/sink/hive/Config.java |  41 ++
 .../sink/hive/HiveDelimitedTextSerializer.java  | 109 ++++
 .../flume/sink/hive/HiveEventSerializer.java    |  38 ++
 .../flume/sink/hive/HiveJsonSerializer.java     |  55 ++
 .../org/apache/flume/sink/hive/HiveSink.java    | 524 +++++++++++++++++++
 .../org/apache/flume/sink/hive/HiveWriter.java  | 426 +++++++++++++++
 .../apache/flume/sink/hive/TestHiveSink.java    | 424 +++++++++++++++
 .../apache/flume/sink/hive/TestHiveWriter.java  | 321 ++++++++++++
 .../org/apache/flume/sink/hive/TestUtil.java    | 228 ++++++++
 .../src/test/resources/log4j.properties         |  26 +
 flume-ng-sinks/pom.xml                          |   2 +
 .../org/apache/flume/source/scribe/Scribe.java  |   9 +-
 pom.xml                                         |  46 +-
 323 files changed, 2659 insertions(+), 19 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/bin/flume-ng
----------------------------------------------------------------------
diff --git a/bin/flume-ng b/bin/flume-ng
index 4b323a6..380169f 100755
--- a/bin/flume-ng
+++ b/bin/flume-ng
@@ -161,6 +161,17 @@ add_HBASE_paths() {
   fi
 }
 
+add_hive_paths(){
+  if [ -d "${HIVE_HOME}/lib" ]; then
+    info "Including Hive libraries found via ($HIVE_HOME) for Hive access"
+    FLUME_CLASSPATH="$FLUME_CLASSPATH:$HIVE_HOME/lib/*"
+  fi
+  if [ -d "${HCAT_HOME}/share/hcatalog" ]; then
+    info "Including HCatalog libraries found via ($HCAT_HOME) for Hive access"
+    FLUME_CLASSPATH="$FLUME_CLASSPATH:${HCAT_HOME}/share/hcatalog/*"
+  fi
+}
+
 set_LD_LIBRARY_PATH(){
 #Append the FLUME_JAVA_LIBRARY_PATH to whatever the user may have specified in
 #flume-env.sh
@@ -417,6 +428,7 @@ fi
 # look for hadoop libs
 add_hadoop_paths
 add_HBASE_paths
+add_hive_paths
 
 # prepend conf dir to classpath
 if [ -n "$opt_conf" ]; then

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/conf/log4j.properties
----------------------------------------------------------------------
diff --git a/conf/log4j.properties b/conf/log4j.properties
index 3918511..c948bff 100644
--- a/conf/log4j.properties
+++ b/conf/log4j.properties
@@ -32,6 +32,7 @@ log4j.logger.org.jboss = WARN
 log4j.logger.org.mortbay = INFO
 log4j.logger.org.apache.avro.ipc.NettyTransceiver = WARN
 log4j.logger.org.apache.hadoop = INFO
+log4j.logger.org.apache.hadoop.hive = ERROR
 
 # Define the root logger to the system property "flume.root.logger".
 log4j.rootLogger=${flume.root.logger}

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java
----------------------------------------------------------------------
diff --git a/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java b/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java
index ac11558..b34a367 100644
--- a/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java
+++ b/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java
@@ -141,14 +141,19 @@ public class SinkConfiguration extends ComponentConfiguration {
      */
     ASYNCHBASE("org.apache.flume.sink.hbase.HBaseSinkConfiguration"),
 
-
     /**
      * MorphlineSolr sink
      *
      * @see org.apache.flume.sink.solr.morphline.MorphlineSolrSink
      */
     MORPHLINE_SOLR("org.apache.flume.sink.solr.morphline" +
-      ".MorphlineSolrSinkConfiguration");
+      ".MorphlineSolrSinkConfiguration"),
+
+    /**
+     * Hive Sink
+     * @see org.apache.flume.sink.hive.HiveSink
+     */
+    HIVE("org.apache.flume.sink.hive.HiveSinkConfiguration");
 
     private final String sinkConfigurationName;
 

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java
----------------------------------------------------------------------
diff --git a/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java b/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java
index 0a1cd7a..edb9f46 100644
--- a/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java
+++ b/flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkType.java
@@ -99,7 +99,13 @@ public enum SinkType {
    *
    * @see org.apache.flume.sink.solr.morphline.MorphlineSolrSink
    */
-  MORPHLINE_SOLR("org.apache.flume.sink.solr.morphline.MorphlineSolrSink");
+  MORPHLINE_SOLR("org.apache.flume.sink.solr.morphline.MorphlineSolrSink"),
+
+  /**
+   * Hive Sink
+   * @see org.apache.flume.sink.hive.HiveSink
+   */
+  HIVE("org.apache.flume.sink.hive.HiveSink");
 
   private final String sinkClassName;
 

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-dist/pom.xml
----------------------------------------------------------------------
diff --git a/flume-ng-dist/pom.xml b/flume-ng-dist/pom.xml
index 4d2ebfe..a083fe2 100644
--- a/flume-ng-dist/pom.xml
+++ b/flume-ng-dist/pom.xml
@@ -77,6 +77,10 @@
           <groupId>org.apache.flume.flume-ng-sinks</groupId>
           <artifactId>flume-dataset-sink</artifactId>
         </dependency>
+        <dependency>
+          <groupId>org.apache.flume.flume-ng-sinks</groupId>
+          <artifactId>flume-hive-sink</artifactId>
+        </dependency>
       </dependencies>
     </profile>
     <profile>
@@ -92,6 +96,10 @@
           <groupId>org.apache.flume.flume-ng-sinks</groupId>
           <artifactId>flume-dataset-sink</artifactId>
         </dependency>
+        <dependency>
+          <groupId>org.apache.flume.flume-ng-sinks</groupId>
+          <artifactId>flume-hive-sink</artifactId>
+        </dependency>
       </dependencies>
     </profile>
   </profiles>

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-doc/sphinx/FlumeUserGuide.rst
----------------------------------------------------------------------
diff --git a/flume-ng-doc/sphinx/FlumeUserGuide.rst b/flume-ng-doc/sphinx/FlumeUserGuide.rst
index 7a1dfce..912342c 100644
--- a/flume-ng-doc/sphinx/FlumeUserGuide.rst
+++ b/flume-ng-doc/sphinx/FlumeUserGuide.rst
@@ -1721,6 +1721,149 @@ The above configuration will round down the timestamp to the last 10th minute. F
 timestamp 11:54:34 AM, June 12, 2012 will cause the hdfs path to become ``/flume/events/2012-06-12/1150/00``.
 
 
+Hive Sink
+~~~~~~~~~
+
+This sink streams events containing delimited text or JSON data directly into a Hive table or partition.
+Events are written using Hive transactions. As soon as a set of events are committed to Hive, they become
+immediately visible to Hive queries. Partitions to which flume will stream to can either be pre-created
+or, optionally, Flume can create them if they are missing. Fields from incoming event data are mapped to
+corresponding columns in the Hive table. **This sink is provided as a preview feature and not recommended
+for use in production.**
+
+======================    ============  ======================================================================
+Name                      Default       Description
+======================    ============  ======================================================================
+**channel**               --
+**type**                  --            The component type name, needs to be ``hive``
+**hive.metastore**        --            Hive metastore URI (eg thrift://a.b.com:9083 )
+**hive.database**         --            Hive database name
+**hive.table**            --            Hive table name
+hive.partition            --            Comma separate list of partition values identifying the partition to write to. May contain escape
+                                        sequences. E.g: If the table is partitioned by (continent: string, country :string, time : string)
+                                        then 'Asia,India,2014-02-26-01-21' will indicate continent=Asia,country=India,time=2014-02-26-01-21
+hive.txnsPerBatchAsk      100           Hive grants a *batch of transactions* instead of single transactions to streaming clients like Flume.
+                                        This setting configures the number of desired transactions per Transaction Batch. Data from all
+                                        transactions in a single batch end up in a single file. Flume will write a maximum of batchSize events
+                                        in each transaction in the batch. This setting in conjunction with batchSize provides control over the
+                                        size of each file. Note that eventually Hive will transparently compact these files into larger files.
+heartBeatInterval         240           (In seconds) Interval between consecutive heartbeats sent to Hive to keep unused transactions from expiring.
+                                        Set this value to 0 to disable heartbeats.
+autoCreatePartitions      true          Flume will automatically create the necessary Hive partitions to stream to
+batchSize                 15000         Max number of events written to Hive in a single Hive transaction
+maxOpenConnections        500           Allow only this number of open connections. If this number is exceeded, the least recently used connection is closed.
+callTimeout               10000         (In milliseconds) Timeout for Hive & HDFS I/O operations, such as openTxn, write, commit, abort.
+**serializer**                          Serializer is responsible for parsing out field from the event and mapping them to columns in the hive table.
+                                        Choice of serializer depends upon the format of the data in the event. Supported serializers: DELIMITED and JSON
+roundUnit                 minute        The unit of the round down value - ``second``, ``minute`` or ``hour``.
+roundValue                1             Rounded down to the highest multiple of this (in the unit configured using hive.roundUnit), less than current time
+timeZone                  Local Time    Name of the timezone that should be used for resolving the escape sequences in partition, e.g. America/Los_Angeles.
+useLocalTimeStamp         false         Use the local time (instead of the timestamp from the event header) while replacing the escape sequences.
+======================    ============  ======================================================================
+
+Following serializers are provided for Hive sink:
+
+**JSON**: Handles UTF8 encoded Json (strict syntax) events and requires no configration. Object names
+in the JSON are mapped directly to columns with the same name in the Hive table.
+Internally uses org.apache.hive.hcatalog.data.JsonSerDe but is independent of the Serde of the Hive table.
+This serializer requires HCatalog to be installed.
+
+**DELIMITED**: Handles simple delimited textual events.
+Internally uses LazySimpleSerde but is independent of the Serde of the Hive table.
+
+==========================    ============  ======================================================================
+Name                          Default       Description
+==========================    ============  ======================================================================
+serializer.delimiter          ,             (Type: string) The field delimiter in the incoming data. To use special
+                                            characters, surround them with double quotes like "\\t"
+**serializer.fieldnames**     --            The mapping from input fields to columns in hive table. Specified as a
+                                            comma separated list (no spaces) of hive table columns names, identifying
+                                            the input fields in order of their occurrence. To skip fields leave the
+                                            column name unspecified. Eg. 'time,,ip,message' indicates the 1st, 3rd
+                                            and 4th fields in input map to time, ip and message columns in the hive table.
+serializer.serdeSeparator     Ctrl-A        (Type: character) Customizes the separator used by underlying serde. There
+                                            can be a gain in efficiency if the fields in serializer.fieldnames are in
+                                            same order as table columns, the serializer.delimiter is same as the
+                                            serializer.serdeSeparator and number of fields in serializer.fieldnames
+                                            is less than or equal to number of table columns, as the fields in incoming
+                                            event body do not need to be reordered to match order of table columns.
+                                            Use single quotes for special characters like '\\t'.
+                                            Ensure input fields do not contain this character. NOTE: If serializer.delimiter
+                                            is a single character, preferably set this to the same character
+==========================    ============  ======================================================================
+
+
+The following are the escape sequences supported:
+
+=========  =================================================
+Alias      Description
+=========  =================================================
+%{host}    Substitute value of event header named "host". Arbitrary header names are supported.
+%t         Unix time in milliseconds
+%a         locale's short weekday name (Mon, Tue, ...)
+%A         locale's full weekday name (Monday, Tuesday, ...)
+%b         locale's short month name (Jan, Feb, ...)
+%B         locale's long month name (January, February, ...)
+%c         locale's date and time (Thu Mar 3 23:05:25 2005)
+%d         day of month (01)
+%D         date; same as %m/%d/%y
+%H         hour (00..23)
+%I         hour (01..12)
+%j         day of year (001..366)
+%k         hour ( 0..23)
+%m         month (01..12)
+%M         minute (00..59)
+%p         locale's equivalent of am or pm
+%s         seconds since 1970-01-01 00:00:00 UTC
+%S         second (00..59)
+%y         last two digits of year (00..99)
+%Y         year (2010)
+%z         +hhmm numeric timezone (for example, -0400)
+=========  =================================================
+
+
+.. note:: For all of the time related escape sequences, a header with the key
+          "timestamp" must exist among the headers of the event (unless ``useLocalTimeStamp`` is set to ``true``). One way to add
+          this automatically is to use the TimestampInterceptor.
+
+Example Hive table :
+
+.. code-block:: properties
+
+ create table weblogs ( id int , msg string )
+     partitioned by (continent string, country string, time string)
+     clustered by (id) into 5 buckets
+     stored as orc;
+
+Example for agent named a1:
+
+.. code-block:: properties
+
+ a1.channels = c1
+ a1.channels.c1.type = memory
+ a1.sinks = k1
+ a1.sinks.k1.type = hive
+ a1.sinks.k1.channel = c1
+ a1.sinks.k1.hive.metastore = thrift://127.0.0.1:9083
+ a1.sinks.k1.hive.database = logsdb
+ a1.sinks.k1.hive.table = weblogs
+ a1.sinks.k1.hive.partition = asia,%{country},%y-%m-%d-%H-%M
+ a1.sinks.k1.useLocalTimeStamp = false
+ a1.sinks.k1.round = true
+ a1.sinks.k1.roundValue = 10
+ a1.sinks.k1.roundUnit = minute
+ a1.sinks.k1.serializer = DELIMITED
+ a1.sinks.k1.serializer.delimiter = "\t"
+ a1.sinks.k1.serializer.serdeSeparator = '\t'
+ a1.sinks.k1.serializer.fieldnames =id,,msg
+
+
+The above configuration will round down the timestamp to the last 10th minute. For example, an event with
+timestamp header set to 11:54:34 AM, June 12, 2012 and 'country' header set to 'india' will evaluate to the
+partition (continent='asia',country='india',time='2012-06-12-11-50'. The serializer is configured to
+accept tab separated input containing three fields and to skip the second field.
+
+
 Logger Sink
 ~~~~~~~~~~~
 

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java
----------------------------------------------------------------------
diff --git a/flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java b/flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java
index ff32c45..3bf632a 100644
--- a/flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java
+++ b/flume-ng-legacy-sources/flume-thrift-source/src/main/java/com/cloudera/flume/handlers/thrift/ThriftFlumeEventServer.java
@@ -209,14 +209,19 @@ public class ThriftFlumeEventServer {
         super("append");
       }
 
-      protected append_args getEmptyArgsInstance() {
+      public append_args getEmptyArgsInstance() {
         return new append_args();
       }
 
-      protected org.apache.thrift.TBase getResult(I iface, append_args args) throws org.apache.thrift.TException {
+      public org.apache.thrift.TBase getResult(I iface,
+           append_args args) throws org.apache.thrift.TException {
         iface.append(args.evt);
         return null;
       }
+
+      public boolean isOneway() {
+        return false;
+      }
     }
 
     private static class close<I extends Iface> extends org.apache.thrift.ProcessFunction<I, close_args> {
@@ -224,15 +229,20 @@ public class ThriftFlumeEventServer {
         super("close");
       }
 
-      protected close_args getEmptyArgsInstance() {
+      public close_args getEmptyArgsInstance() {
         return new close_args();
       }
 
-      protected close_result getResult(I iface, close_args args) throws org.apache.thrift.TException {
+      public close_result getResult(I iface, close_args args) throws org.apache
+          .thrift.TException {
         close_result result = new close_result();
         iface.close();
         return result;
       }
+
+      public boolean isOneway() {
+        return false;
+      }
     }
 
   }

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftLegacy/TestThriftLegacySource.java
----------------------------------------------------------------------
diff --git a/flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftLegacy/TestThriftLegacySource.java b/flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftLegacy/TestThriftLegacySource.java
index 8e08f22..d8a6872 100644
--- a/flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftLegacy/TestThriftLegacySource.java
+++ b/flume-ng-legacy-sources/flume-thrift-source/src/test/java/org/apache/flume/source/thriftLegacy/TestThriftLegacySource.java
@@ -145,7 +145,6 @@ public class TestThriftLegacySource {
   @Test
   public void testLifecycle() throws InterruptedException {
     bind();
-    Thread.sleep(1000);
     stop();
   }
 

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java
----------------------------------------------------------------------
diff --git a/flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java b/flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java
index 7f966b0..67a64ac 100644
--- a/flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java
+++ b/flume-ng-sdk/src/main/java/org/apache/flume/thrift/ThriftSourceProtocol.java
@@ -228,15 +228,20 @@ public class ThriftSourceProtocol {
         super("append");
       }
 
-      protected append_args getEmptyArgsInstance() {
+      public append_args getEmptyArgsInstance() {
         return new append_args();
       }
 
-      protected append_result getResult(I iface, append_args args) throws org.apache.thrift.TException {
+      public append_result getResult(I iface, append_args args) throws org
+          .apache.thrift.TException {
         append_result result = new append_result();
         result.success = iface.append(args.event);
         return result;
       }
+
+      protected boolean isOneway() {
+        return false;
+      }
     }
 
     private static class appendBatch<I extends Iface> extends org.apache.thrift.ProcessFunction<I, appendBatch_args> {
@@ -244,15 +249,20 @@ public class ThriftSourceProtocol {
         super("appendBatch");
       }
 
-      protected appendBatch_args getEmptyArgsInstance() {
+      public appendBatch_args getEmptyArgsInstance() {
         return new appendBatch_args();
       }
 
-      protected appendBatch_result getResult(I iface, appendBatch_args args) throws org.apache.thrift.TException {
+      public appendBatch_result getResult(I iface, appendBatch_args args)
+          throws org.apache.thrift.TException {
         appendBatch_result result = new appendBatch_result();
         result.success = iface.appendBatch(args.events);
         return result;
       }
+
+      protected boolean isOneway() {
+        return false;
+      }
     }
 
   }

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/db.lck
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/db.lck b/flume-ng-sinks/flume-hive-sink/metastore_db/db.lck
new file mode 100644
index 0000000..45e0595
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/db.lck differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/dbex.lck
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/dbex.lck b/flume-ng-sinks/flume-hive-sink/metastore_db/dbex.lck
new file mode 100644
index 0000000..720d64f
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/dbex.lck differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/log/log.ctrl
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/log/log.ctrl b/flume-ng-sinks/flume-hive-sink/metastore_db/log/log.ctrl
new file mode 100644
index 0000000..bc4ad4c
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/log/log.ctrl differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/log/log3.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/log/log3.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/log/log3.dat
new file mode 100644
index 0000000..1e8b5d6
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/log/log3.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/log/log4.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/log/log4.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/log/log4.dat
new file mode 100644
index 0000000..9efa133
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/log/log4.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/log/logmirror.ctrl
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/log/logmirror.ctrl b/flume-ng-sinks/flume-hive-sink/metastore_db/log/logmirror.ctrl
new file mode 100644
index 0000000..bc4ad4c
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/log/logmirror.ctrl differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c10.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c10.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c10.dat
new file mode 100644
index 0000000..efc8218
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c10.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c101.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c101.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c101.dat
new file mode 100644
index 0000000..6b7fd00
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c101.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c111.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c111.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c111.dat
new file mode 100644
index 0000000..6a3ccab
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c111.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c121.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c121.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c121.dat
new file mode 100644
index 0000000..77dd266
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c121.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c130.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c130.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c130.dat
new file mode 100644
index 0000000..462c9af
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c130.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c141.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c141.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c141.dat
new file mode 100644
index 0000000..c56f879
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c141.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c150.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c150.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c150.dat
new file mode 100644
index 0000000..6dd64e6
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c150.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c161.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c161.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c161.dat
new file mode 100644
index 0000000..99c062f
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c161.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c171.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c171.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c171.dat
new file mode 100644
index 0000000..e98af2e
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c171.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c180.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c180.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c180.dat
new file mode 100644
index 0000000..97663ed
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c180.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c191.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c191.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c191.dat
new file mode 100644
index 0000000..2c64b9e
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c191.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1a1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1a1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1a1.dat
new file mode 100644
index 0000000..1cd053a
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1a1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1b1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1b1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1b1.dat
new file mode 100644
index 0000000..9d0fe20
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1b1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1c0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1c0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1c0.dat
new file mode 100644
index 0000000..c5b91e2
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1c0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1d1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1d1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1d1.dat
new file mode 100644
index 0000000..451f02f
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1d1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e0.dat
new file mode 100644
index 0000000..6255f85
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e90.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e90.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e90.dat
new file mode 100644
index 0000000..de30561
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1e90.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ea1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ea1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ea1.dat
new file mode 100644
index 0000000..1a4f3ae
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ea1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1eb0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1eb0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1eb0.dat
new file mode 100644
index 0000000..de30561
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1eb0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ec1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ec1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ec1.dat
new file mode 100644
index 0000000..f0b7823
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ec1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ed0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ed0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ed0.dat
new file mode 100644
index 0000000..de30561
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ed0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ee0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ee0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ee0.dat
new file mode 100644
index 0000000..1a75cd6
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ee0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ef0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ef0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ef0.dat
new file mode 100644
index 0000000..de30561
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1ef0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f01.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f01.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f01.dat
new file mode 100644
index 0000000..ade0cfa
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f01.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f1.dat
new file mode 100644
index 0000000..2d14e15
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f11.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f11.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f11.dat
new file mode 100644
index 0000000..15209bc
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f11.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f20.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f20.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f20.dat
new file mode 100644
index 0000000..1a75cd6
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f20.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f30.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f30.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f30.dat
new file mode 100644
index 0000000..de30561
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f30.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f41.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f41.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f41.dat
new file mode 100644
index 0000000..cec4024
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f41.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f50.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f50.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f50.dat
new file mode 100644
index 0000000..1a75cd6
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c1f50.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c20.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c20.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c20.dat
new file mode 100644
index 0000000..6a51e91
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c20.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c200.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c200.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c200.dat
new file mode 100644
index 0000000..7050478
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c200.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c211.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c211.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c211.dat
new file mode 100644
index 0000000..44b1495
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c211.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c221.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c221.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c221.dat
new file mode 100644
index 0000000..7e1b717
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c221.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c230.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c230.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c230.dat
new file mode 100644
index 0000000..79db150
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c230.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c241.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c241.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c241.dat
new file mode 100644
index 0000000..6277c52
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c241.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c251.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c251.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c251.dat
new file mode 100644
index 0000000..66dd561
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c251.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c260.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c260.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c260.dat
new file mode 100644
index 0000000..25f81fd
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c260.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c271.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c271.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c271.dat
new file mode 100644
index 0000000..51cde57
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c271.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c281.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c281.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c281.dat
new file mode 100644
index 0000000..cfed875
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c281.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c290.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c290.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c290.dat
new file mode 100644
index 0000000..4d10db4
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c290.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2a1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2a1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2a1.dat
new file mode 100644
index 0000000..8e2ed6a
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2a1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2b1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2b1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2b1.dat
new file mode 100644
index 0000000..2a29692
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2b1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2c1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2c1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2c1.dat
new file mode 100644
index 0000000..5511575
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2c1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2d0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2d0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2d0.dat
new file mode 100644
index 0000000..60e3e4f
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2d0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2e1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2e1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2e1.dat
new file mode 100644
index 0000000..fe5b8bd
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2e1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2f0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2f0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2f0.dat
new file mode 100644
index 0000000..d854b4b
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c2f0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c300.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c300.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c300.dat
new file mode 100644
index 0000000..2053e01
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c300.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c31.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c31.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c31.dat
new file mode 100644
index 0000000..813fe3b
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c31.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c311.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c311.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c311.dat
new file mode 100644
index 0000000..f60c260
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c311.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c321.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c321.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c321.dat
new file mode 100644
index 0000000..a9d7453
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c321.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c331.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c331.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c331.dat
new file mode 100644
index 0000000..85ee72b
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c331.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c340.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c340.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c340.dat
new file mode 100644
index 0000000..d99b11a
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c340.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c351.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c351.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c351.dat
new file mode 100644
index 0000000..f822f4c
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c351.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c361.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c361.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c361.dat
new file mode 100644
index 0000000..b5c8f25
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c361.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c371.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c371.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c371.dat
new file mode 100644
index 0000000..ad11f01
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c371.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c380.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c380.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c380.dat
new file mode 100644
index 0000000..987d6ba
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c380.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c391.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c391.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c391.dat
new file mode 100644
index 0000000..f2c4a79
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c391.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3a1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3a1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3a1.dat
new file mode 100644
index 0000000..0040fce
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3a1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3b1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3b1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3b1.dat
new file mode 100644
index 0000000..f970c9e
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3b1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3c0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3c0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3c0.dat
new file mode 100644
index 0000000..4d061cf
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3c0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3d1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3d1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3d1.dat
new file mode 100644
index 0000000..45c9fa2
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3d1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3e1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3e1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3e1.dat
new file mode 100644
index 0000000..48f53e6
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3e1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3f1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3f1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3f1.dat
new file mode 100644
index 0000000..08acdce
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c3f1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c400.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c400.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c400.dat
new file mode 100644
index 0000000..1e8976f
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c400.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c41.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c41.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c41.dat
new file mode 100644
index 0000000..88245f0
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c41.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c411.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c411.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c411.dat
new file mode 100644
index 0000000..8aba2fb
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c411.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c421.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c421.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c421.dat
new file mode 100644
index 0000000..65775ee
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c421.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c430.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c430.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c430.dat
new file mode 100644
index 0000000..55c948d
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c430.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c441.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c441.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c441.dat
new file mode 100644
index 0000000..3948b2a
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c441.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c451.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c451.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c451.dat
new file mode 100644
index 0000000..fe1ab73
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c451.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c461.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c461.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c461.dat
new file mode 100644
index 0000000..e6d9854
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c461.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c51.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c51.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c51.dat
new file mode 100644
index 0000000..daff727
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c51.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c540.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c540.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c540.dat
new file mode 100644
index 0000000..b495560
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c540.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c551.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c551.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c551.dat
new file mode 100644
index 0000000..c700059
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c551.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c560.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c560.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c560.dat
new file mode 100644
index 0000000..b2861f8
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c560.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c571.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c571.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c571.dat
new file mode 100644
index 0000000..da66110
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c571.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c581.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c581.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c581.dat
new file mode 100644
index 0000000..ad4a0d4
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c581.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c591.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c591.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c591.dat
new file mode 100644
index 0000000..3425513
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c591.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5a0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5a0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5a0.dat
new file mode 100644
index 0000000..423c1f5
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5a0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5b1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5b1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5b1.dat
new file mode 100644
index 0000000..11da382
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5b1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5c0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5c0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5c0.dat
new file mode 100644
index 0000000..aa4bef9
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5c0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5d1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5d1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5d1.dat
new file mode 100644
index 0000000..c37d1b6
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5d1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5e0.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5e0.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5e0.dat
new file mode 100644
index 0000000..0bd366a
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5e0.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5f1.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5f1.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5f1.dat
new file mode 100644
index 0000000..0514996
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c5f1.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c60.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c60.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c60.dat
new file mode 100644
index 0000000..954b83b
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c60.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c600.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c600.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c600.dat
new file mode 100644
index 0000000..83367f7
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c600.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c611.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c611.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c611.dat
new file mode 100644
index 0000000..a8a8e86
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c611.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c620.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c620.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c620.dat
new file mode 100644
index 0000000..c888f93
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c620.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c631.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c631.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c631.dat
new file mode 100644
index 0000000..695438d
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c631.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c640.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c640.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c640.dat
new file mode 100644
index 0000000..5aa4d30
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c640.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c651.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c651.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c651.dat
new file mode 100644
index 0000000..61451af
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c651.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c660.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c660.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c660.dat
new file mode 100644
index 0000000..d8d7104
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c660.dat differ

http://git-wip-us.apache.org/repos/asf/flume/blob/5dfd3d96/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c671.dat
----------------------------------------------------------------------
diff --git a/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c671.dat b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c671.dat
new file mode 100644
index 0000000..414405c
Binary files /dev/null and b/flume-ng-sinks/flume-hive-sink/metastore_db/seg0/c671.dat differ


Mime
View raw message