You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by hs...@apache.org on 2015/02/10 08:16:20 UTC
[4/4] flume git commit: FLUME-1734. Add a Hive Sink based on Hive
Streaming support.
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/a7f9255a
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/a7f9255a
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/a7f9255a
Branch: refs/heads/trunk
Commit: a7f9255a83beb222e1f3e871dff2d44568fa3f43
Parents: 9907764
Author: Hari Shreedharan <hs...@apache.org>
Authored: Mon Feb 9 23:15:02 2015 -0800
Committer: Hari Shreedharan <hs...@apache.org>
Committed: Mon Feb 9 23:15:02 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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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/a7f9255a/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