Path	Lines of Code
notification/src/main/java/org/apache/atlas/hook/AtlasHook.java	272
notification/src/main/java/org/apache/atlas/hook/AtlasHookException.java	17
notification/src/main/java/org/apache/atlas/hook/AtlasTopicCreator.java	60
notification/src/main/java/org/apache/atlas/hook/FailedMessagesLogger.java	9
notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaConsumer.java	110
notification/src/main/java/org/apache/atlas/kafka/AtlasKafkaMessage.java	56
notification/src/main/java/org/apache/atlas/kafka/EmbeddedKafkaServer.java	143
notification/src/main/java/org/apache/atlas/kafka/KafkaNotification.java	327
notification/src/main/java/org/apache/atlas/kafka/NotificationProvider.java	55
notification/src/main/java/org/apache/atlas/notification/AbstractMessageDeserializer.java	10
notification/src/main/java/org/apache/atlas/notification/AbstractNotification.java	136
notification/src/main/java/org/apache/atlas/notification/AbstractNotificationConsumer.java	9
notification/src/main/java/org/apache/atlas/notification/AtlasNotificationMessageDeserializer.java	210
notification/src/main/java/org/apache/atlas/notification/IncompatibleVersionException.java	6
notification/src/main/java/org/apache/atlas/notification/MessageDeserializer.java	4
notification/src/main/java/org/apache/atlas/notification/NotificationConsumer.java	14
notification/src/main/java/org/apache/atlas/notification/NotificationException.java	22
notification/src/main/java/org/apache/atlas/notification/NotificationInterface.java	28
notification/src/main/java/org/apache/atlas/notification/SplitMessageAggregator.java	40
notification/src/main/java/org/apache/atlas/notification/entity/EntityMessageDeserializer.java	22
notification/src/main/java/org/apache/atlas/notification/hook/HookMessageDeserializer.java	22
notification/src/main/java/org/apache/atlas/notification/rest/RestNotification.java	109
notification/src/main/java/org/apache/atlas/notification/spool/Archiver.java	85
notification/src/main/java/org/apache/atlas/notification/spool/AtlasFileSpool.java	132
notification/src/main/java/org/apache/atlas/notification/spool/FileOperations.java	40
notification/src/main/java/org/apache/atlas/notification/spool/IndexManagement.java	360
notification/src/main/java/org/apache/atlas/notification/spool/Publisher.java	162
notification/src/main/java/org/apache/atlas/notification/spool/SpoolConfiguration.java	109
notification/src/main/java/org/apache/atlas/notification/spool/SpoolUtils.java	141
notification/src/main/java/org/apache/atlas/notification/spool/Spooler.java	94
notification/src/main/java/org/apache/atlas/notification/spool/models/IndexRecord.java	164
notification/src/main/java/org/apache/atlas/notification/spool/models/IndexRecords.java	55
notification/src/main/java/org/apache/atlas/notification/spool/utils/local/FileLockedReadWrite.java	43
notification/src/main/java/org/apache/atlas/notification/spool/utils/local/FileOpAppend.java	17
notification/src/main/java/org/apache/atlas/notification/spool/utils/local/FileOpCompaction.java	28
notification/src/main/java/org/apache/atlas/notification/spool/utils/local/FileOpDelete.java	23
notification/src/main/java/org/apache/atlas/notification/spool/utils/local/FileOpRead.java	35
notification/src/main/java/org/apache/atlas/notification/spool/utils/local/FileOpUpdate.java	32
notification/src/main/java/org/apache/atlas/notification/spool/utils/local/FileOperation.java	128
notification/src/main/java/org/apache/atlas/util/CommandHandlerUtility.java	56