This is an automated email from the ASF dual-hosted git repository.
ppkarwasz pushed a change to branch remove-sinks
in repository https://gitbox.apache.org/repos/asf/logging-flume.git
from 2aed333ff Remove sinks
add 547226f83 Disable Windows build
add 36f8ac120 Move Avro & Thrift. Switch to java.time from joda (#431)
add e4a995d00 Merge remote-tracking branch 'apache/trunk' into remove-sinks
No new revisions were added by this update.
Summary of changes:
.github/workflows/build.yml | 2 +-
bin/flume-ng | 2 +-
flume-bom/pom.xml | 7 +-
.../org/apache/flume/channel/file/FileChannel.java | 4 +-
.../apache/flume/channel/file/TestFileChannel.java | 2 +-
.../channel/file/TestFileChannelErrorMetrics.java | 2 +-
.../org/apache/flume/channel/file/TestUtils.java | 2 +-
.../file/encryption/TestFileChannelEncryption.java | 2 +-
.../flume/channel/SpillableMemoryChannel.java | 4 +-
.../flume/channel/TestSpillableMemoryChannel.java | 4 +-
.../TestLoadBalancingLog4jAppender.java | 1 -
.../clients/log4jappender/TestLog4jAppender.java | 1 -
.../log4jappender/TestLog4jAppenderWithAvro.java | 1 -
.../java/org/apache/flume/conf/sink/SinkType.java | 21 +-
.../org/apache/flume/conf/source/SourceType.java | 6 +-
flume-ng-core/pom.xml | 113 ----
.../src/main/java/org/apache/flume/Channel.java | 1 +
.../flume/channel/BasicChannelSemantics.java | 2 +-
.../flume/channel/BasicTransactionSemantics.java | 2 +-
.../org/apache/flume/channel/ChannelProcessor.java | 2 +-
.../org/apache/flume/channel/ChannelUtils.java | 2 +-
.../org/apache/flume/channel/MemoryChannel.java | 4 +-
.../flume/channel/PseudoTxnMemoryChannel.java | 2 +-
.../formatter/output/RollTimePathManager.java | 9 +-
.../RegexExtractorInterceptorMillisSerializer.java | 13 +-
.../flume/serialization/EventDeserializerType.java | 20 +-
.../flume/serialization/EventSerializerType.java | 20 +-
.../serialization/TransientPositionTracker.java | 0
.../org/apache/flume/sink/AbstractRpcSink.java | 4 +-
.../java/org/apache/flume/source/NetcatSource.java | 2 +-
.../org/apache/flume/source/NetcatUdpSource.java | 2 +-
.../flume/source/SequenceGeneratorSource.java | 2 +-
.../java/org/apache/flume/source/StressSource.java | 2 +-
.../java/org/apache/flume/source/SyslogParser.java | 79 +--
.../org/apache/flume/source/SyslogTcpSource.java | 2 +-
.../org/apache/flume/source/SyslogUDPSource.java | 2 +-
.../org/apache/flume/source/http/HTTPSource.java | 2 +-
.../channel/AbstractBasicChannelSemanticsTest.java | 2 +-
.../java/org/apache/flume/channel/MockChannel.java | 2 +-
.../apache/flume/channel/TestChannelProcessor.java | 2 +-
.../org/apache/flume/channel/TestChannelUtils.java | 2 +-
.../apache/flume/channel/TestMemoryChannel.java | 2 +-
.../channel/TestMemoryChannelConcurrency.java | 2 +-
.../flume/formatter/output/TestBucketPath.java | 12 +-
.../interceptor/TestRegexExtractorInterceptor.java | 16 +-
...tRegexExtractorInterceptorMillisSerializer.java | 14 +-
.../apache/flume/sink/TestDefaultSinkFactory.java | 24 +-
.../flume/sink/TestLoadBalancingSinkProcessor.java | 2 +-
.../org/apache/flume/sink/TestRollingFileSink.java | 2 +-
.../org/apache/flume/source/TestAvroSource.java | 610 --------------------
.../flume/source/TestDefaultSourceFactory.java | 29 +-
.../flume/source/TestMultiportSyslogTCPSource.java | 13 +-
.../org/apache/flume/source/TestNetcatSource.java | 2 +-
.../flume/source/TestSequenceGeneratorSource.java | 2 +-
.../org/apache/flume/source/TestStressSource.java | 2 +-
.../org/apache/flume/source/TestSyslogParser.java | 125 +++-
.../apache/flume/source/TestSyslogTcpSource.java | 6 +-
.../apache/flume/source/TestSyslogUdpSource.java | 6 +-
.../org/apache/flume/source/TestThriftSource.java | 383 -------------
flume-ng-dist/pom.xml | 26 +-
flume-ng-embedded-agent/pom.xml | 6 +
.../apache/flume/agent/embedded/EmbeddedAgent.java | 2 +-
.../flume/agent/embedded/EmbeddedSource.java | 2 +-
flume-ng-node/pom.xml | 4 +-
.../node/TestAbstractConfigurationProvider.java | 52 +-
flume-ng-sdk/pom.xml | 173 +-----
.../src/main/java/org/apache/flume/Context.java | 0
.../org/apache/flume/annotations/Disposable.java | 0
.../flume/annotations/InterfaceAudience.java | 0
.../flume/annotations/InterfaceStability.java | 0
.../org/apache/flume/annotations/Recyclable.java | 0
.../org/apache/flume/api/FailoverRpcClient.java | 2 +-
.../org/apache/flume/api/RpcClientFactory.java | 79 ++-
.../java/org/apache/flume/event}/EventReader.java | 2 +-
.../apache/flume/event}/ReliableEventReader.java | 2 +-
.../flume/event}/SimpleTextLineEventReader.java | 3 +-
.../apache/flume/exception}/ChannelException.java | 2 +-
.../flume/exception}/ChannelFullException.java | 2 +-
.../flume/instrumentation/ChannelCounter.java | 0
.../flume/instrumentation/ChannelCounterMBean.java | 0
.../instrumentation/MonitoredCounterGroup.java | 0
.../apache/flume/instrumentation/SinkCounter.java | 2 +-
.../flume/instrumentation/SinkCounterMBean.java | 0
.../flume/instrumentation/SourceCounter.java | 2 +-
.../flume/instrumentation/SourceCounterMBean.java | 0
.../flume/serialization/DecodeErrorPolicy.java | 0
.../flume/serialization/EventDeserializer.java | 0
.../flume/serialization/LengthMeasurable.java | 0
.../flume/serialization/LineDeserializer.java | 0
.../flume/serialization/PositionTracker.java | 0
.../apache/flume/serialization/RemoteMarkable.java | 0
.../org/apache/flume/serialization/Resettable.java | 0
.../serialization/ResettableFileInputStream.java | 0
.../flume/serialization/ResettableInputStream.java | 0
.../org/apache/flume/serialization/Seekable.java | 0
...SpoolDirectorySourceConfigurationConstants.java | 0
.../org/apache/flume/tools/PlatformDetect.java | 0
.../org/apache/flume/api/ThriftTestingSource.java | 282 ---------
.../flume/event}/TestBufferedLineReader.java | 18 +-
.../org/apache/flume/source/jms/JMSSource.java | 2 +-
.../org/apache/flume/source/jms/TestJMSSource.java | 2 +-
.../source/taildir/ReliableTaildirEventReader.java | 2 +-
.../apache/flume/source/taildir/TaildirSource.java | 2 +-
.../flume/source/taildir/TestTaildirSource.java | 2 +-
flume-ng-sources/pom.xml | 1 -
flume-ng-tests/pom.xml | 4 +
flume-ng-tests/src/test/resources/log4j2.xml | 2 +-
flume-parent/pom.xml | 152 +----
flume-rpc/flume-rpc-avro/pom.xml | 222 +++++++
.../src/main/avro/TransferStateFileMeta.avsc | 0
.../flume-rpc-avro}/src/main/avro/flume.avdl | 0
.../flume/rpc/avro/client}/AvroCLIClient.java | 6 +-
.../flume/rpc/avro/client}/NettyAvroRpcClient.java | 15 +-
.../serialization/AbstractAvroEventSerializer.java | 8 +-
.../avro}/serialization/AvroEventDeserializer.java | 6 +-
.../AvroEventSerializerConfigurationConstants.java | 2 +-
.../serialization/DurablePositionTracker.java | 4 +-
.../FlumeEventAvroEventSerializer.java | 3 +-
.../ReliableSpoolingFileEventReader.java | 4 +-
.../org/apache/flume/rpc/avro}/sink/AvroSink.java | 9 +-
.../apache/flume/rpc/avro}/source/AvroSource.java | 25 +-
.../rpc/avro}/source/SpoolDirectorySource.java | 9 +-
.../flume/rpc}/api/TestFailoverRpcClient.java | 7 +-
.../org/apache/flume/rpc/avro}/RpcTestUtils.java | 6 +-
.../rpc/avro}/TestLoadBalancingRpcClient.java | 9 +-
.../flume/rpc/avro}/TestRpcClientFactory.java | 6 +-
.../rpc/avro/client}/TestNettyAvroRpcClient.java | 12 +-
.../serialization/SyslogAvroEventSerializer.java | 32 +-
.../serialization/TestAvroEventDeserializer.java | 6 +-
.../serialization/TestDurablePositionTracker.java | 3 +-
.../TestFlumeEventAvroEventSerializer.java | 3 +-
.../TestReliableSpoolingFileEventReader.java | 33 +-
.../TestResettableFileInputStream.java | 6 +-
.../serialization}/TestSpoolingFileLineReader.java | 2 +-
.../TestSyslogAvroEventSerializer.java | 4 +-
.../apache/flume/rpc/avro}/sink/TestAvroSink.java | 6 +-
.../rpc/avro}/sink/TestDefaultSinkFactory.java | 6 +-
.../apache/flume/rpc/avro}/source/MockSource.java | 2 +-
.../rpc/avro}/source/TestDefaultSourceFactory.java | 11 +-
.../rpc/avro}/source/TestSpoolDirectorySource.java | 9 +-
.../node/TestAbstractConfigurationProvider.java | 6 +-
.../resources/TestResettableFileInputStream_1.avro | Bin
.../TestResettableFileInputStream_1.truncated.avro | Bin
.../src/test/resources/certs/gencerts.sh | 0
.../src/test/resources/certs/rootca.conf | 0
.../src/test/resources/certs/server.conf | 0
.../src/test/resources/jettykeystore | Bin
.../src/test/resources/keystorefile.jks | Bin
.../flume-rpc-avro}/src/test/resources/log4j2.xml | 1 +
.../src/test/resources/server.flume-crt.pem | 0
.../src/test/resources/server.flume-keystore.p12 | Bin
.../src/test/resources/server.flume.pem | 0
.../flume-rpc-avro}/src/test/resources/server.p12 | Bin
.../src/test/resources/syslog_event.avsc | 0
.../src/test/resources/truststore.jks | Bin
.../src/test/resources/truststorefile.jks | Bin
flume-rpc/flume-rpc-thrift/pom.xml | 216 +++++++
.../java/org/apache/flume/rpc}/thrift/Status.java | 4 +-
.../apache/flume/rpc}/thrift/ThriftFlumeEvent.java | 5 +-
.../flume/rpc}/thrift/ThriftSourceProtocol.java | 16 +-
.../rpc/thrift}/api/SecureRpcClientFactory.java | 5 +-
.../rpc/thrift}/api/SecureThriftRpcClient.java | 5 +-
.../flume/rpc/thrift/client}/ThriftRpcClient.java | 20 +-
.../apache/flume/rpc/thrift}/sink/ThriftSink.java | 9 +-
.../flume/rpc/thrift}/source/ThriftSource.java | 21 +-
.../flume-rpc-thrift}/src/main/thrift/aslv2 | 0
.../flume-rpc-thrift}/src/main/thrift/flume.thrift | 0
.../flume/rpc/thrift}/TestThriftRpcClient.java | 6 +-
.../flume/rpc/thrift/ThriftTestingSource.java | 636 +++++++++++++++++++++
.../flume/rpc/thrift}/sink/TestThriftSink.java | 6 +-
.../flume/rpc/thrift}/source/MockSource.java | 2 +-
.../thrift}/source/TestDefaultSourceFactory.java | 35 +-
.../src/test/resources/certs/gencerts.sh | 0
.../src/test/resources/certs/rootca.conf | 0
.../src/test/resources/certs/server.conf | 0
.../src/test/resources/keystorefile.jks | Bin
.../src/test/resources/log4j2.xml | 1 +
.../src/test/resources/truststore.jks | Bin
.../src/test/resources/truststorefile.jks | Bin
flume-rpc/pom.xml | 162 ++++++
pom.xml | 6 +-
181 files changed, 1931 insertions(+), 2145 deletions(-)
rename flume-ng-core/src/{test =>
main}/java/org/apache/flume/serialization/TransientPositionTracker.java (100%)
delete mode 100644
flume-ng-core/src/test/java/org/apache/flume/source/TestAvroSource.java
delete mode 100644
flume-ng-core/src/test/java/org/apache/flume/source/TestThriftSource.java
rename {flume-ng-configuration =>
flume-ng-sdk}/src/main/java/org/apache/flume/Context.java (100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/annotations/Disposable.java (100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/annotations/InterfaceAudience.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/annotations/InterfaceStability.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/annotations/Recyclable.java (100%)
rename {flume-ng-core/src/main/java/org/apache/flume/client/avro =>
flume-ng-sdk/src/main/java/org/apache/flume/event}/EventReader.java (98%)
rename {flume-ng-core/src/main/java/org/apache/flume/client/avro =>
flume-ng-sdk/src/main/java/org/apache/flume/event}/ReliableEventReader.java
(97%)
rename {flume-ng-core/src/main/java/org/apache/flume/client/avro =>
flume-ng-sdk/src/main/java/org/apache/flume/event}/SimpleTextLineEventReader.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-ng-sdk/src/main/java/org/apache/flume/exception}/ChannelException.java
(97%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-ng-sdk/src/main/java/org/apache/flume/exception}/ChannelFullException.java
(97%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/ChannelCounter.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/ChannelCounterMBean.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/MonitoredCounterGroup.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/SinkCounter.java
(98%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/SinkCounterMBean.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/SourceCounter.java
(98%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/instrumentation/SourceCounterMBean.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/DecodeErrorPolicy.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/EventDeserializer.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/LengthMeasurable.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/LineDeserializer.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/PositionTracker.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/RemoteMarkable.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/Resettable.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/ResettableInputStream.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/serialization/Seekable.java (100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/source/SpoolDirectorySourceConfigurationConstants.java
(100%)
rename {flume-ng-core =>
flume-ng-sdk}/src/main/java/org/apache/flume/tools/PlatformDetect.java (100%)
delete mode 100644
flume-ng-sdk/src/test/java/org/apache/flume/api/ThriftTestingSource.java
rename {flume-ng-core/src/test/java/org/apache/flume/client/avro =>
flume-ng-sdk/src/test/java/org/apache/flume/event}/TestBufferedLineReader.java
(89%)
create mode 100644 flume-rpc/flume-rpc-avro/pom.xml
rename {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/main/avro/TransferStateFileMeta.avsc (100%)
rename {flume-ng-sdk => flume-rpc/flume-rpc-avro}/src/main/avro/flume.avdl
(100%)
rename {flume-ng-core/src/main/java/org/apache/flume/client/avro =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro/client}/AvroCLIClient.java
(96%)
rename {flume-ng-sdk/src/main/java/org/apache/flume/api =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro/client}/NettyAvroRpcClient.java
(97%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/serialization/AbstractAvroEventSerializer.java
(86%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/serialization/AvroEventDeserializer.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/serialization/AvroEventSerializerConfigurationConstants.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/serialization/DurablePositionTracker.java
(97%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/serialization/FlumeEventAvroEventSerializer.java
(95%)
rename {flume-ng-core/src/main/java/org/apache/flume/client/avro =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro/serialization}/ReliableSpoolingFileEventReader.java
(99%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/sink/AvroSink.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/source/AvroSource.java
(98%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/main/java/org/apache/flume/rpc/avro}/source/SpoolDirectorySource.java
(97%)
rename {flume-ng-sdk/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc}/api/TestFailoverRpcClient.java
(96%)
rename {flume-ng-sdk/src/test/java/org/apache/flume/api =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/RpcTestUtils.java
(98%)
rename {flume-ng-sdk/src/test/java/org/apache/flume/api =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/TestLoadBalancingRpcClient.java
(98%)
rename {flume-ng-sdk/src/test/java/org/apache/flume/api =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/TestRpcClientFactory.java
(96%)
rename {flume-ng-sdk/src/test/java/org/apache/flume/api =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro/client}/TestNettyAvroRpcClient.java
(97%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/SyslogAvroEventSerializer.java
(91%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/TestAvroEventDeserializer.java
(95%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/TestDurablePositionTracker.java
(96%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/TestFlumeEventAvroEventSerializer.java
(97%)
rename {flume-ng-core/src/test/java/org/apache/flume/client/avro =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro/serialization}/TestReliableSpoolingFileEventReader.java
(95%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/TestResettableFileInputStream.java
(98%)
rename {flume-ng-core/src/test/java/org/apache/flume/client/avro =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro/serialization}/TestSpoolingFileLineReader.java
(99%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/serialization/TestSyslogAvroEventSerializer.java
(96%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/sink/TestAvroSink.java
(99%)
copy {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/sink/TestDefaultSinkFactory.java
(91%)
copy {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/source/MockSource.java
(97%)
copy {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/source/TestDefaultSourceFactory.java
(87%)
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc/avro}/source/TestSpoolDirectorySource.java
(98%)
copy {flume-ng-node/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-avro/src/test/java/org/apache/flume/rpc}/node/TestAbstractConfigurationProvider.java
(98%)
rename {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/TestResettableFileInputStream_1.avro
(100%)
rename {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/TestResettableFileInputStream_1.truncated.avro
(100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/certs/gencerts.sh (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/certs/rootca.conf (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/certs/server.conf (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/jettykeystore (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/keystorefile.jks (100%)
copy {flume-ng-channels/flume-file-channel =>
flume-rpc/flume-rpc-avro}/src/test/resources/log4j2.xml (94%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/server.flume-crt.pem (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/server.flume-keystore.p12 (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/server.flume.pem (100%)
copy {flume-ng-core => flume-rpc/flume-rpc-avro}/src/test/resources/server.p12
(100%)
rename {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/syslog_event.avsc (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/truststore.jks (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-avro}/src/test/resources/truststorefile.jks (100%)
create mode 100644 flume-rpc/flume-rpc-thrift/pom.xml
rename {flume-ng-sdk/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc}/thrift/Status.java
(95%)
rename {flume-ng-sdk/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc}/thrift/ThriftFlumeEvent.java
(99%)
rename {flume-ng-sdk/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc}/thrift/ThriftSourceProtocol.java
(99%)
rename {flume-ng-auth/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc/thrift}/api/SecureRpcClientFactory.java
(90%)
rename {flume-ng-auth/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc/thrift}/api/SecureThriftRpcClient.java
(96%)
rename {flume-ng-sdk/src/main/java/org/apache/flume/api =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc/thrift/client}/ThriftRpcClient.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc/thrift}/sink/ThriftSink.java
(96%)
rename {flume-ng-core/src/main/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/main/java/org/apache/flume/rpc/thrift}/source/ThriftSource.java
(97%)
rename {flume-ng-sdk => flume-rpc/flume-rpc-thrift}/src/main/thrift/aslv2
(100%)
rename {flume-ng-sdk =>
flume-rpc/flume-rpc-thrift}/src/main/thrift/flume.thrift (100%)
rename {flume-ng-sdk/src/test/java/org/apache/flume/api =>
flume-rpc/flume-rpc-thrift/src/test/java/org/apache/flume/rpc/thrift}/TestThriftRpcClient.java
(96%)
create mode 100644
flume-rpc/flume-rpc-thrift/src/test/java/org/apache/flume/rpc/thrift/ThriftTestingSource.java
rename {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/test/java/org/apache/flume/rpc/thrift}/sink/TestThriftSink.java
(98%)
copy {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/test/java/org/apache/flume/rpc/thrift}/source/MockSource.java
(97%)
copy {flume-ng-core/src/test/java/org/apache/flume =>
flume-rpc/flume-rpc-thrift/src/test/java/org/apache/flume/rpc/thrift}/source/TestDefaultSourceFactory.java
(68%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/certs/gencerts.sh (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/certs/rootca.conf (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/certs/server.conf (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/keystorefile.jks (100%)
copy {flume-ng-channels/flume-file-channel =>
flume-rpc/flume-rpc-thrift}/src/test/resources/log4j2.xml (94%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/truststore.jks (100%)
copy {flume-ng-core =>
flume-rpc/flume-rpc-thrift}/src/test/resources/truststorefile.jks (100%)
create mode 100644 flume-rpc/pom.xml
