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 <[email protected]> Authored: Mon Feb 9 23:15:02 2015 -0800 Committer: Hari Shreedharan <[email protected]> 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
