path	# lines of code
src/com/amazon/kinesis/streaming/agent/UserDefinedCredentialsProvider.java	141
src/com/amazon/kinesis/streaming/agent/package-info.java	1
src/com/amazon/kinesis/streaming/agent/providers/CLIWebIdentityTokenCredentialsProvider.java	90
src/com/amazon/kinesis/streaming/agent/IHeartbeatProvider.java	4
src/com/amazon/kinesis/streaming/agent/config/ConfigurationConverter.java	18
src/com/amazon/kinesis/streaming/agent/config/BooleanConverter.java	30
src/com/amazon/kinesis/streaming/agent/config/StringConverterWrapper.java	15
src/com/amazon/kinesis/streaming/agent/config/AgentConfiguration.java	142
src/com/amazon/kinesis/streaming/agent/config/package-info.java	1
src/com/amazon/kinesis/streaming/agent/config/AgentOptions.java	70
src/com/amazon/kinesis/streaming/agent/config/PathConverter.java	19
src/com/amazon/kinesis/streaming/agent/config/Configuration.java	337
src/com/amazon/kinesis/streaming/agent/config/ConfigurationException.java	10
src/com/amazon/kinesis/streaming/agent/HeartbeatService.java	25
src/com/amazon/kinesis/streaming/agent/ByteBuffers.java	131
src/com/amazon/kinesis/streaming/agent/AgentAWSCredentialsProviderChain.java	19
src/com/amazon/kinesis/streaming/agent/Agent.java	368
src/com/amazon/kinesis/streaming/agent/AgentAWSCredentialsProvider.java	32
src/com/amazon/kinesis/streaming/agent/ByteBufferInputStream.java	64
src/com/amazon/kinesis/streaming/agent/tailing/TrackedFileRotationAnalyzer.java	180
src/com/amazon/kinesis/streaming/agent/tailing/TrackedFile.java	109
src/com/amazon/kinesis/streaming/agent/tailing/KinesisRecord.java	48
src/com/amazon/kinesis/streaming/agent/tailing/FirehoseParser.java	18
src/com/amazon/kinesis/streaming/agent/tailing/RecordBuffer.java	100
src/com/amazon/kinesis/streaming/agent/tailing/FileId.java	34
src/com/amazon/kinesis/streaming/agent/tailing/package-info.java	1
src/com/amazon/kinesis/streaming/agent/tailing/KinesisConstants.java	18
src/com/amazon/kinesis/streaming/agent/tailing/BufferSendResult.java	30
src/com/amazon/kinesis/streaming/agent/tailing/AbstractRecord.java	86
src/com/amazon/kinesis/streaming/agent/tailing/AbstractParser.java	438
src/com/amazon/kinesis/streaming/agent/tailing/ISplitter.java	5
src/com/amazon/kinesis/streaming/agent/tailing/checkpoints/FileCheckpointStore.java	13
src/com/amazon/kinesis/streaming/agent/tailing/checkpoints/package-info.java	1
src/com/amazon/kinesis/streaming/agent/tailing/checkpoints/Checkpointer.java	29
src/com/amazon/kinesis/streaming/agent/tailing/checkpoints/FileCheckpoint.java	23
src/com/amazon/kinesis/streaming/agent/tailing/checkpoints/SQLiteFileCheckpointStore.java	272
src/com/amazon/kinesis/streaming/agent/tailing/FileFlow.java	151
src/com/amazon/kinesis/streaming/agent/tailing/FirehoseFileFlow.java	132
src/com/amazon/kinesis/streaming/agent/tailing/SourceFileTracker.java	293
src/com/amazon/kinesis/streaming/agent/tailing/FileFlowFactory.java	21
src/com/amazon/kinesis/streaming/agent/tailing/AggregationSplitter.java	32
src/com/amazon/kinesis/streaming/agent/tailing/FirehoseConstants.java	14
src/com/amazon/kinesis/streaming/agent/tailing/KinesisParser.java	18
src/com/amazon/kinesis/streaming/agent/tailing/RegexSplitter.java	46
src/com/amazon/kinesis/streaming/agent/tailing/FileTailer.java	343
src/com/amazon/kinesis/streaming/agent/tailing/FirehoseSender.java	170
src/com/amazon/kinesis/streaming/agent/tailing/AbstractSender.java	22
src/com/amazon/kinesis/streaming/agent/tailing/IRecord.java	15
src/com/amazon/kinesis/streaming/agent/tailing/FirehoseRecord.java	18
src/com/amazon/kinesis/streaming/agent/tailing/ISender.java	9
src/com/amazon/kinesis/streaming/agent/tailing/AsyncPublisher.java	155
src/com/amazon/kinesis/streaming/agent/tailing/KinesisSender.java	172
src/com/amazon/kinesis/streaming/agent/tailing/KinesisFileFlow.java	128
src/com/amazon/kinesis/streaming/agent/tailing/AsyncPublisherThrottler.java	153
src/com/amazon/kinesis/streaming/agent/tailing/PublishingQueue.java	383
src/com/amazon/kinesis/streaming/agent/tailing/SingleLineSplitter.java	10
src/com/amazon/kinesis/streaming/agent/tailing/IParser.java	14
src/com/amazon/kinesis/streaming/agent/tailing/AsyncPublisherService.java	124
src/com/amazon/kinesis/streaming/agent/tailing/SourceFile.java	72
src/com/amazon/kinesis/streaming/agent/tailing/SimplePublisher.java	166
src/com/amazon/kinesis/streaming/agent/tailing/TrackedFileList.java	73
src/com/amazon/kinesis/streaming/agent/Constants.java	11
src/com/amazon/kinesis/streaming/agent/processing/parsers/BaseLogParser.java	57
src/com/amazon/kinesis/streaming/agent/processing/parsers/PatternConstants.java	55
src/com/amazon/kinesis/streaming/agent/processing/parsers/ApacheLogParser.java	85
src/com/amazon/kinesis/streaming/agent/processing/parsers/SysLogParser.java	59
src/com/amazon/kinesis/streaming/agent/processing/processors/SingleLineDataConverter.java	36
src/com/amazon/kinesis/streaming/agent/processing/processors/AddMetadataConverter.java	47
src/com/amazon/kinesis/streaming/agent/processing/processors/PluggableDataConverter.java	44
src/com/amazon/kinesis/streaming/agent/processing/processors/BracketsDataConverter.java	21
src/com/amazon/kinesis/streaming/agent/processing/processors/CSVToJSONDataConverter.java	52
src/com/amazon/kinesis/streaming/agent/processing/processors/LogToJSONDataConverter.java	43
src/com/amazon/kinesis/streaming/agent/processing/processors/AgentDataConverterChain.java	56
src/com/amazon/kinesis/streaming/agent/processing/processors/AddEC2MetadataConverter.java	99
src/com/amazon/kinesis/streaming/agent/processing/interfaces/IDataConverter.java	7
src/com/amazon/kinesis/streaming/agent/processing/interfaces/IJSONPrinter.java	6
src/com/amazon/kinesis/streaming/agent/processing/interfaces/ILogParser.java	9
src/com/amazon/kinesis/streaming/agent/processing/utils/ProcessingUtilsFactory.java	103
src/com/amazon/kinesis/streaming/agent/processing/utils/SimpleJSONPrinter.java	16
src/com/amazon/kinesis/streaming/agent/processing/utils/PrettyJSONPrinter.java	17
src/com/amazon/kinesis/streaming/agent/processing/exceptions/DataConversionException.java	18
src/com/amazon/kinesis/streaming/agent/processing/exceptions/LogParsingException.java	10
src/com/amazon/kinesis/streaming/agent/metrics/Metrics.java	74
src/com/amazon/kinesis/streaming/agent/metrics/AbstractMetricsScope.java	60
src/com/amazon/kinesis/streaming/agent/metrics/CWMetricsFactory.java	41
src/com/amazon/kinesis/streaming/agent/metrics/LogMetricsScope.java	38
src/com/amazon/kinesis/streaming/agent/metrics/CWMetricsScope.java	22
src/com/amazon/kinesis/streaming/agent/metrics/package-info.java	1
src/com/amazon/kinesis/streaming/agent/metrics/IMetricsFactory.java	4
src/com/amazon/kinesis/streaming/agent/metrics/LogMetricsFactory.java	7
src/com/amazon/kinesis/streaming/agent/metrics/CompositeMetricsScope.java	42
src/com/amazon/kinesis/streaming/agent/metrics/AccumulatingMetricsScope.java	46
src/com/amazon/kinesis/streaming/agent/metrics/CWPublisherRunnable.java	123
src/com/amazon/kinesis/streaming/agent/metrics/IMetricsContext.java	4
src/com/amazon/kinesis/streaming/agent/metrics/CompositeMetricsFactory.java	28
src/com/amazon/kinesis/streaming/agent/metrics/NullMetricsFactory.java	7
src/com/amazon/kinesis/streaming/agent/metrics/CWMetricKey.java	28
src/com/amazon/kinesis/streaming/agent/metrics/MetricDatumWithKey.java	26
src/com/amazon/kinesis/streaming/agent/metrics/NullMetricsScope.java	10
src/com/amazon/kinesis/streaming/agent/metrics/MetricAccumulatingQueue.java	55
src/com/amazon/kinesis/streaming/agent/metrics/IMetricsScope.java	14
src/com/amazon/kinesis/streaming/agent/metrics/NestedMetricsScope.java	41
src/com/amazon/kinesis/streaming/agent/metrics/DefaultCWMetricsPublisher.java	42
src/com/amazon/kinesis/streaming/agent/metrics/ICWMetricsPublisher.java	5
src/com/amazon/kinesis/streaming/agent/AgentContext.java	199
tst/com/amazon/kinesis/streaming/agent/TestUserDefinedCredentialsProvider.java	18
tst/com/amazon/kinesis/streaming/agent/AgentContextTest.java	84
tst/com/amazon/kinesis/streaming/agent/ByteBuffersTest.java	127
tst/com/amazon/kinesis/streaming/agent/config/ConfigurationTest.java	194
tst/com/amazon/kinesis/streaming/agent/config/AgentConfigurationTest.java	93
tst/com/amazon/kinesis/streaming/agent/config/BooleanConverterTest.java	40
tst/com/amazon/kinesis/streaming/agent/testing/TestUtils.java	472
tst/com/amazon/kinesis/streaming/agent/testing/package-info.java	1
tst/com/amazon/kinesis/streaming/agent/testing/TestUtilsTest.java	163
tst/com/amazon/kinesis/streaming/agent/ByteBufferInputStreamTest.java	78
tst/com/amazon/kinesis/streaming/agent/tailing/FirehoseRecordTest.java	43
tst/com/amazon/kinesis/streaming/agent/tailing/RecordBufferTest.java	97
tst/com/amazon/kinesis/streaming/agent/tailing/AsyncPublisherTest.java	165
tst/com/amazon/kinesis/streaming/agent/tailing/FirehoseParserTest.java	108
tst/com/amazon/kinesis/streaming/agent/tailing/SimplePublisherTest.java	42
tst/com/amazon/kinesis/streaming/agent/tailing/FirehoseFileFlowTest.java	44
tst/com/amazon/kinesis/streaming/agent/tailing/KinesisParserTest.java	49
tst/com/amazon/kinesis/streaming/agent/tailing/AgentEnduranceTest.java	31
tst/com/amazon/kinesis/streaming/agent/tailing/FileTailerEnduranceTest.java	36
tst/com/amazon/kinesis/streaming/agent/tailing/PublishingQueueTest.java	518
tst/com/amazon/kinesis/streaming/agent/tailing/testing/RenameFileRotator.java	30
tst/com/amazon/kinesis/streaming/agent/tailing/testing/CreateFileRotator.java	39
tst/com/amazon/kinesis/streaming/agent/tailing/testing/FileRotatorTestBase.java	154
tst/com/amazon/kinesis/streaming/agent/tailing/testing/TruncateFileRotatorTest.java	22
tst/com/amazon/kinesis/streaming/agent/tailing/testing/package-info.java	1
tst/com/amazon/kinesis/streaming/agent/tailing/testing/FileSender.java	207
tst/com/amazon/kinesis/streaming/agent/tailing/testing/CopyFileRotatorTest.java	34
tst/com/amazon/kinesis/streaming/agent/tailing/testing/RememberedTrackedFile.java	55
tst/com/amazon/kinesis/streaming/agent/tailing/testing/TestableSourceFileTracker.java	227
tst/com/amazon/kinesis/streaming/agent/tailing/testing/TestAgentContext.java	102
tst/com/amazon/kinesis/streaming/agent/tailing/testing/CopyFileRotator.java	57
tst/com/amazon/kinesis/streaming/agent/tailing/testing/TestableFileTailer.java	89
tst/com/amazon/kinesis/streaming/agent/tailing/testing/TailingTestBase.java	365
tst/com/amazon/kinesis/streaming/agent/tailing/testing/RenameFileRotatorTest.java	8
tst/com/amazon/kinesis/streaming/agent/tailing/testing/RotatingFileGenerator.java	53
tst/com/amazon/kinesis/streaming/agent/tailing/testing/CreateFileRotatorTest.java	8
tst/com/amazon/kinesis/streaming/agent/tailing/testing/TruncateFileRotator.java	76
tst/com/amazon/kinesis/streaming/agent/tailing/testing/FileRotator.java	246
tst/com/amazon/kinesis/streaming/agent/tailing/testing/RecordGenerator.java	152
tst/com/amazon/kinesis/streaming/agent/tailing/KinesisRecordTest.java	63
tst/com/amazon/kinesis/streaming/agent/tailing/checkpoints/CheckpointerTest.java	65
tst/com/amazon/kinesis/streaming/agent/tailing/checkpoints/FileCheckpointTest.java	44
tst/com/amazon/kinesis/streaming/agent/tailing/checkpoints/SQLiteFileCheckpointStoreTest.java	172
tst/com/amazon/kinesis/streaming/agent/tailing/FileIdTest.java	35
tst/com/amazon/kinesis/streaming/agent/tailing/KinesisFileFlowTest.java	91
tst/com/amazon/kinesis/streaming/agent/tailing/SourceFileTrackerTest.java	302
tst/com/amazon/kinesis/streaming/agent/tailing/TrackedFileRotationAnalyzerTest.java	179
tst/com/amazon/kinesis/streaming/agent/tailing/AbstractParserTest.java	749
tst/com/amazon/kinesis/streaming/agent/tailing/AsyncPublisherServiceTest.java	160
tst/com/amazon/kinesis/streaming/agent/tailing/AsyncPublisherThrottlerTest.java	259
tst/com/amazon/kinesis/streaming/agent/tailing/FileFlowTest.java	231
tst/com/amazon/kinesis/streaming/agent/tailing/AgentEndToEndTest.java	76
tst/com/amazon/kinesis/streaming/agent/tailing/TrackedFileTest.java	100
tst/com/amazon/kinesis/streaming/agent/tailing/FirehoseSenderTest.java	182
tst/com/amazon/kinesis/streaming/agent/tailing/KinesisSenderTest.java	206
tst/com/amazon/kinesis/streaming/agent/tailing/SourceFileTest.java	144
tst/com/amazon/kinesis/streaming/agent/tailing/AggregationSplitterTest.java	140
tst/com/amazon/kinesis/streaming/agent/tailing/FileTailerTest.java	375
tst/com/amazon/kinesis/streaming/agent/processing/processors/DataConverterTest.java	192
tst/com/amazon/kinesis/streaming/agent/AgentAWSCredentialsProviderChainTest.java	81
tst/com/amazon/kinesis/streaming/agent/metrics/BaseMetricsScopeTest.java	68
tst/com/amazon/kinesis/streaming/agent/metrics/MetricAccumulatingQueueTest.java	63
tst/com/amazon/kinesis/streaming/agent/metrics/CWPublisherRunnableTest.java	122
tst/com/amazon/kinesis/streaming/agent/metrics/TestHelper.java	19
tst/com/amazon/kinesis/streaming/agent/metrics/DefaultCWMetricsPublisherTest.java	73
tst/log4j2-test.yml	16