FLUME-2937. Integrate checkstyle for non-test classes
authorMike Percy <mpercy@cloudera.com>
Sun, 26 Jun 2016 09:57:37 +0000 (02:57 -0700)
committerMike Percy <mpercy@cloudera.com>
Thu, 30 Jun 2016 02:16:57 +0000 (19:16 -0700)
commit2252fb1938a4fd578f88c64eb444c74777c46212
tree12a4b0aad6879b4c51033e4f0cf3e31093ae943c
parent2fe393898f420d100117ca277cce198858e2c24f
FLUME-2937. Integrate checkstyle for non-test classes

Based on the Google checkstyle file with modifications.

The changes here do not change the generated Java bytecode (after
stripping line numbers). They are syntax / whitespace ONLY.

Code review: https://reviews.apache.org/r/49403/

Reviewed by Hari.
244 files changed:
flume-checkstyle/pom.xml [new file with mode: 0644]
flume-checkstyle/src/main/resources/flume/checkstyle-suppressions.xml [new file with mode: 0644]
flume-checkstyle/src/main/resources/flume/checkstyle.xml [new file with mode: 0644]
flume-ng-auth/src/main/java/org/apache/flume/api/SecureRpcClientFactory.java
flume-ng-auth/src/main/java/org/apache/flume/api/SecureThriftRpcClient.java
flume-ng-auth/src/main/java/org/apache/flume/auth/FlumeAuthenticationUtil.java
flume-ng-auth/src/main/java/org/apache/flume/auth/KerberosAuthenticator.java
flume-ng-auth/src/main/java/org/apache/flume/auth/KerberosUser.java
flume-ng-auth/src/main/java/org/apache/flume/auth/SimpleAuthenticator.java
flume-ng-auth/src/main/java/org/apache/flume/auth/UGIExecutor.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/BadCheckpointException.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/CheckpointRebuilder.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Commit.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/CorruptEventException.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFactory.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFile.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFileV2.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventQueueBackingStoreFileV3.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/EventUtils.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannel.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FileChannelConfiguration.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEvent.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventPointer.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Log.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFile.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileFactory.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileRetryableIOException.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileV2.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogFileV3.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogRecord.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/LogUtils.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Pair.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Put.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/ReplayHandler.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Rollback.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Serialization.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/Take.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/TransactionEventRecord.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/TransactionIDOracle.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/WritableUtils.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/WriteOrderOracle.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/AESCTRNoPaddingProvider.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/CipherProvider.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/CipherProviderFactory.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/CipherProviderType.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/DecryptionFailureException.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/JCEFileKeyProvider.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/encryption/KeyProviderType.java
flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/proto/ProtosFactory.java
flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/ConfigurationConstants.java
flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannel.java
flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannelProvider.java
flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/DerbySchemaHandler.java
flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java
flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionImpl.java
flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/SchemaHandler.java
flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/SchemaHandlerFactory.java
flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannel.java
flume-ng-channels/flume-kafka-channel/src/main/java/org/apache/flume/channel/kafka/KafkaChannelConfiguration.java
flume-ng-channels/flume-spillable-memory-channel/src/main/java/org/apache/flume/channel/SpillableMemoryChannel.java
flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/LoadBalancingLog4jAppender.java
flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAppender.java
flume-ng-clients/flume-ng-log4jappender/src/main/java/org/apache/flume/clients/log4jappender/Log4jAvroHeaders.java
flume-ng-configuration/src/main/java/org/apache/flume/Context.java
flume-ng-configuration/src/main/java/org/apache/flume/conf/BasicConfigurationConstants.java
flume-ng-configuration/src/main/java/org/apache/flume/conf/ComponentConfiguration.java
flume-ng-configuration/src/main/java/org/apache/flume/conf/ComponentConfigurationFactory.java
flume-ng-configuration/src/main/java/org/apache/flume/conf/FlumeConfiguration.java
flume-ng-configuration/src/main/java/org/apache/flume/conf/FlumeConfigurationError.java
flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkConfiguration.java
flume-ng-configuration/src/main/java/org/apache/flume/conf/sink/SinkGroupConfiguration.java
flume-ng-configuration/src/main/java/org/apache/flume/conf/source/SourceConfiguration.java
flume-ng-core/src/main/java/org/apache/flume/ChannelFactory.java
flume-ng-core/src/main/java/org/apache/flume/ChannelSelector.java
flume-ng-core/src/main/java/org/apache/flume/Clock.java
flume-ng-core/src/main/java/org/apache/flume/SinkFactory.java
flume-ng-core/src/main/java/org/apache/flume/SinkRunner.java
flume-ng-core/src/main/java/org/apache/flume/SourceFactory.java
flume-ng-core/src/main/java/org/apache/flume/SourceRunner.java
flume-ng-core/src/main/java/org/apache/flume/SystemClock.java
flume-ng-core/src/main/java/org/apache/flume/Transaction.java
flume-ng-core/src/main/java/org/apache/flume/annotations/Disposable.java
flume-ng-core/src/main/java/org/apache/flume/annotations/InterfaceStability.java
flume-ng-core/src/main/java/org/apache/flume/annotations/Recyclable.java
flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannel.java
flume-ng-core/src/main/java/org/apache/flume/channel/AbstractChannelSelector.java
flume-ng-core/src/main/java/org/apache/flume/channel/BasicTransactionSemantics.java
flume-ng-core/src/main/java/org/apache/flume/channel/ChannelSelectorFactory.java
flume-ng-core/src/main/java/org/apache/flume/channel/DefaultChannelFactory.java
flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java
flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java
flume-ng-core/src/main/java/org/apache/flume/channel/PseudoTxnMemoryChannel.java
flume-ng-core/src/main/java/org/apache/flume/channel/ReplicatingChannelSelector.java
flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java
flume-ng-core/src/main/java/org/apache/flume/client/avro/ReliableSpoolingFileEventReader.java
flume-ng-core/src/main/java/org/apache/flume/event/EventHelper.java
flume-ng-core/src/main/java/org/apache/flume/formatter/output/BucketPath.java
flume-ng-core/src/main/java/org/apache/flume/formatter/output/DefaultPathManager.java
flume-ng-core/src/main/java/org/apache/flume/formatter/output/PathManager.java
flume-ng-core/src/main/java/org/apache/flume/formatter/output/PathManagerFactory.java
flume-ng-core/src/main/java/org/apache/flume/formatter/output/PathManagerType.java
flume-ng-core/src/main/java/org/apache/flume/formatter/output/RollTimePathManager.java
flume-ng-core/src/main/java/org/apache/flume/instrumentation/ChannelCounter.java
flume-ng-core/src/main/java/org/apache/flume/instrumentation/GangliaServer.java
flume-ng-core/src/main/java/org/apache/flume/instrumentation/MonitoredCounterGroup.java
flume-ng-core/src/main/java/org/apache/flume/instrumentation/MonitoringType.java
flume-ng-core/src/main/java/org/apache/flume/instrumentation/SinkCounter.java
flume-ng-core/src/main/java/org/apache/flume/instrumentation/SourceCounter.java
flume-ng-core/src/main/java/org/apache/flume/instrumentation/http/HTTPMetricsServer.java
flume-ng-core/src/main/java/org/apache/flume/instrumentation/kafka/KafkaChannelCounter.java
flume-ng-core/src/main/java/org/apache/flume/instrumentation/util/JMXPollUtil.java
flume-ng-core/src/main/java/org/apache/flume/interceptor/HostInterceptor.java
flume-ng-core/src/main/java/org/apache/flume/interceptor/RegexExtractorInterceptor.java
flume-ng-core/src/main/java/org/apache/flume/interceptor/RegexFilteringInterceptor.java
flume-ng-core/src/main/java/org/apache/flume/interceptor/SearchAndReplaceInterceptor.java
flume-ng-core/src/main/java/org/apache/flume/interceptor/StaticInterceptor.java
flume-ng-core/src/main/java/org/apache/flume/interceptor/TimestampInterceptor.java
flume-ng-core/src/main/java/org/apache/flume/lifecycle/LifecycleAware.java
flume-ng-core/src/main/java/org/apache/flume/lifecycle/LifecycleSupervisor.java
flume-ng-core/src/main/java/org/apache/flume/serialization/AvroEventDeserializer.java
flume-ng-core/src/main/java/org/apache/flume/serialization/BodyTextEventSerializer.java
flume-ng-core/src/main/java/org/apache/flume/serialization/HeaderAndBodyTextEventSerializer.java
flume-ng-core/src/main/java/org/apache/flume/serialization/LineDeserializer.java
flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java
flume-ng-core/src/main/java/org/apache/flume/sink/AbstractRpcSink.java
flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSink.java
flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkProcessor.java
flume-ng-core/src/main/java/org/apache/flume/sink/AbstractSinkSelector.java
flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkFactory.java
flume-ng-core/src/main/java/org/apache/flume/sink/DefaultSinkProcessor.java
flume-ng-core/src/main/java/org/apache/flume/sink/FailoverSinkProcessor.java
flume-ng-core/src/main/java/org/apache/flume/sink/LoadBalancingSinkProcessor.java
flume-ng-core/src/main/java/org/apache/flume/sink/LoggerSink.java
flume-ng-core/src/main/java/org/apache/flume/sink/NullSink.java
flume-ng-core/src/main/java/org/apache/flume/sink/RollingFileSink.java
flume-ng-core/src/main/java/org/apache/flume/sink/SinkProcessorFactory.java
flume-ng-core/src/main/java/org/apache/flume/sink/ThriftSink.java
flume-ng-core/src/main/java/org/apache/flume/source/AbstractEventDrivenSource.java
flume-ng-core/src/main/java/org/apache/flume/source/AbstractPollableSource.java
flume-ng-core/src/main/java/org/apache/flume/source/AbstractSource.java
flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java
flume-ng-core/src/main/java/org/apache/flume/source/BasicSourceSemantics.java
flume-ng-core/src/main/java/org/apache/flume/source/DefaultSourceFactory.java
flume-ng-core/src/main/java/org/apache/flume/source/ExecSource.java
flume-ng-core/src/main/java/org/apache/flume/source/ExecSourceConfigurationConstants.java
flume-ng-core/src/main/java/org/apache/flume/source/MultiportSyslogTCPSource.java
flume-ng-core/src/main/java/org/apache/flume/source/NetcatSourceConfigurationConstants.java
flume-ng-core/src/main/java/org/apache/flume/source/PollableSourceRunner.java
flume-ng-core/src/main/java/org/apache/flume/source/SequenceGeneratorSource.java
flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySource.java
flume-ng-core/src/main/java/org/apache/flume/source/SpoolDirectorySourceConfigurationConstants.java
flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java
flume-ng-core/src/main/java/org/apache/flume/source/SyslogParser.java
flume-ng-core/src/main/java/org/apache/flume/source/SyslogTcpSource.java
flume-ng-core/src/main/java/org/apache/flume/source/SyslogUDPSource.java
flume-ng-core/src/main/java/org/apache/flume/source/SyslogUtils.java
flume-ng-core/src/main/java/org/apache/flume/source/ThriftSource.java
flume-ng-core/src/main/java/org/apache/flume/source/http/BLOBHandler.java
flume-ng-core/src/main/java/org/apache/flume/source/http/HTTPSource.java
flume-ng-core/src/main/java/org/apache/flume/source/http/JSONHandler.java
flume-ng-core/src/main/java/org/apache/flume/tools/DirectMemoryUtils.java
flume-ng-core/src/main/java/org/apache/flume/tools/GetJavaProperty.java
flume-ng-core/src/main/java/org/apache/flume/tools/TimestampRoundDownUtil.java
flume-ng-core/src/main/java/org/apache/flume/tools/VersionInfo.java
flume-ng-embedded-agent/src/main/java/org/apache/flume/agent/embedded/EmbeddedAgent.java
flume-ng-embedded-agent/src/main/java/org/apache/flume/agent/embedded/EmbeddedAgentConfiguration.java
flume-ng-embedded-agent/src/main/java/org/apache/flume/agent/embedded/EmbeddedSource.java
flume-ng-legacy-sources/flume-thrift-source/src/main/java/org/apache/flume/source/thriftLegacy/ThriftLegacySource.java
flume-ng-node/src/main/java/org/apache/flume/node/AbstractConfigurationProvider.java
flume-ng-node/src/main/java/org/apache/flume/node/Application.java
flume-ng-node/src/main/java/org/apache/flume/node/ConfigurationProvider.java
flume-ng-node/src/main/java/org/apache/flume/node/PollingPropertiesFileConfigurationProvider.java
flume-ng-node/src/main/java/org/apache/flume/node/SimpleMaterializedConfiguration.java
flume-ng-sdk/src/main/java/org/apache/flume/api/AbstractRpcClient.java
flume-ng-sdk/src/main/java/org/apache/flume/api/FailoverRpcClient.java
flume-ng-sdk/src/main/java/org/apache/flume/api/HostInfo.java
flume-ng-sdk/src/main/java/org/apache/flume/api/LoadBalancingRpcClient.java
flume-ng-sdk/src/main/java/org/apache/flume/api/NettyAvroRpcClient.java
flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientConfigurationConstants.java
flume-ng-sdk/src/main/java/org/apache/flume/api/RpcClientFactory.java
flume-ng-sdk/src/main/java/org/apache/flume/api/ThriftRpcClient.java
flume-ng-sdk/src/main/java/org/apache/flume/event/EventBuilder.java
flume-ng-sdk/src/main/java/org/apache/flume/event/JSONEvent.java
flume-ng-sdk/src/main/java/org/apache/flume/event/SimpleEvent.java
flume-ng-sdk/src/main/java/org/apache/flume/util/OrderSelector.java
flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/DatasetSink.java
flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/NonRecoverableEventException.java
flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/parser/EntityParserFactory.java
flume-ng-sinks/flume-dataset-sink/src/main/java/org/apache/flume/sink/kite/policy/FailurePolicyFactory.java
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/AbstractHDFSWriter.java
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketClosedException.java
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/BucketWriter.java
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSCompressedDataStream.java
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSDataStream.java
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSSequenceFile.java
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/KerberosUser.java
flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/SequenceFileSerializerType.java
flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveDelimitedTextSerializer.java
flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveEventSerializer.java
flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveSink.java
flume-ng-sinks/flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveWriter.java
flume-ng-sinks/flume-irc-sink/src/main/java/org/apache/flume/sink/irc/IRCSink.java
flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/AbstractElasticSearchIndexRequestBuilderFactory.java
flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchIndexRequestBuilderFactory.java
flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/ElasticSearchSink.java
flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/EventSerializerIndexRequestBuilderFactory.java
flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchClientFactory.java
flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchRestClient.java
flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/ElasticSearchTransportClient.java
flume-ng-sinks/flume-ng-elasticsearch-sink/src/main/java/org/apache/flume/sink/elasticsearch/client/RoundRobinList.java
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHBaseSink.java
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/AsyncHbaseEventSerializer.java
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HBaseSink.java
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/HbaseEventSerializer.java
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/RegexHbaseEventSerializer.java
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleAsyncHbaseEventSerializer.java
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleHbaseEventSerializer.java
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleRowKeyGenerator.java
flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSinkConstants.java
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobDeserializer.java
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/BlobHandler.java
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineHandlerImpl.java
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineInterceptor.java
flume-ng-sinks/flume-ng-morphline-solr-sink/src/main/java/org/apache/flume/sink/solr/morphline/MorphlineSink.java
flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/DefaultJMSMessageConverter.java
flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/InitialContextFactory.java
flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSMessageConsumer.java
flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSMessageConsumerFactory.java
flume-ng-sources/flume-jms-source/src/main/java/org/apache/flume/source/jms/JMSSource.java
flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSource.java
flume-ng-sources/flume-kafka-source/src/main/java/org/apache/flume/source/kafka/KafkaSourceConstants.java
flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/ReliableTaildirEventReader.java
flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TailFile.java
flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TaildirMatcher.java
flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TaildirSource.java
flume-ng-sources/flume-taildir-source/src/main/java/org/apache/flume/source/taildir/TaildirSourceConfigurationConstants.java
flume-ng-tests/src/test/java/org/apache/flume/test/agent/TestRpcClientCommunicationFailure.java
flume-tools/src/main/java/org/apache/flume/tools/FileChannelIntegrityTool.java
flume-tools/src/main/java/org/apache/flume/tools/FlumeToolType.java
flume-tools/src/main/java/org/apache/flume/tools/FlumeToolsMain.java
pom.xml