ASF Git Repos - flume.git/commit

author	Mike Percy <mpercy@cloudera.com>
	Sun, 26 Jun 2016 09:57:37 +0000 (02:57 -0700)
committer	Mike Percy <mpercy@cloudera.com>
	Thu, 30 Jun 2016 02:16:57 +0000 (19:16 -0700)
commit	2252fb1938a4fd578f88c64eb444c74777c46212
tree	12a4b0aad6879b4c51033e4f0cf3e31093ae943c	tree \| snapshot
parent	2fe393898f420d100117ca277cce198858e2c24f	commit \| diff

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

Apache Flume

RSS Atom