Path	Lines of Code
cassandra/src/main/java/org/apache/ignite/activestore/ActiveCacheStore.java	140
cassandra/src/main/java/org/apache/ignite/activestore/CommandService.java	16
cassandra/src/main/java/org/apache/ignite/activestore/Exporter.java	24
cassandra/src/main/java/org/apache/ignite/activestore/IdSequencer.java	4
cassandra/src/main/java/org/apache/ignite/activestore/KeyValueListener.java	8
cassandra/src/main/java/org/apache/ignite/activestore/KeyValueManager.java	15
cassandra/src/main/java/org/apache/ignite/activestore/KeyValueProvider.java	18
cassandra/src/main/java/org/apache/ignite/activestore/KeyValueReader.java	8
cassandra/src/main/java/org/apache/ignite/activestore/Metadata.java	35
cassandra/src/main/java/org/apache/ignite/activestore/MetadataManager.java	20
cassandra/src/main/java/org/apache/ignite/activestore/MetadataProvider.java	5
cassandra/src/main/java/org/apache/ignite/activestore/Tree.java	14
cassandra/src/main/java/org/apache/ignite/activestore/commons/Container.java	110
cassandra/src/main/java/org/apache/ignite/activestore/commons/Injection.java	225
cassandra/src/main/java/org/apache/ignite/activestore/commons/Lazy.java	36
cassandra/src/main/java/org/apache/ignite/activestore/commons/Reference.java	5
cassandra/src/main/java/org/apache/ignite/activestore/impl/ActiveStoreConfiguration.java	15
cassandra/src/main/java/org/apache/ignite/activestore/impl/BackupJob.java	41
cassandra/src/main/java/org/apache/ignite/activestore/impl/BaseActiveStoreConfiguration.java	74
cassandra/src/main/java/org/apache/ignite/activestore/impl/CommandServiceImpl.java	313
cassandra/src/main/java/org/apache/ignite/activestore/impl/DataCapturerBusConfiguration.java	68
cassandra/src/main/java/org/apache/ignite/activestore/impl/DefaultMetadataManager.java	70
cassandra/src/main/java/org/apache/ignite/activestore/impl/InMemoryMetadataManager.java	13
cassandra/src/main/java/org/apache/ignite/activestore/impl/KeyValueManagerImpl.java	119
cassandra/src/main/java/org/apache/ignite/activestore/impl/MergeTablesJob.java	53
cassandra/src/main/java/org/apache/ignite/activestore/impl/MetadataProviderImpl.java	42
cassandra/src/main/java/org/apache/ignite/activestore/impl/MetadataTree.java	182
cassandra/src/main/java/org/apache/ignite/activestore/impl/ProcessAllKeysJob.java	44
cassandra/src/main/java/org/apache/ignite/activestore/impl/RestoreJob.java	46
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/CassandraActiveStoreConfiguration.java	67
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/CassandraHelperEx.java	19
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/CassandraKeyValueProvider.java	280
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/CassandraMetadataManager.java	82
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/SnapshotHelper.java	20
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/datasource/DataSource.java	362
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/persistence/KeyValuePersistenceSettingsRegistry.java	95
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/persistence/PersistenceController.java	265
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/persistence/PublicKeyValuePersistenceSettings.java	219
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/persistence/PublicKeyspacePersistenceSettings.java	226
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/persistence/SnapshotAwareController.java	72
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/session/CassandraSession.java	16
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/session/CassandraSessionImpl.java	805
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/session/TransactionExecutionAssistance.java	11
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/session/adapter/GenericAssistant.java	15
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/session/adapter/GenericBatchExecutionAssistant.java	29
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/session/adapter/GenericExecutionAssistant.java	7
cassandra/src/main/java/org/apache/ignite/activestore/impl/cassandra/session/pool/SessionPool.java	113
cassandra/src/main/java/org/apache/ignite/activestore/impl/export/FileChecksumHelper.java	29
cassandra/src/main/java/org/apache/ignite/activestore/impl/export/FileExporter.java	132
cassandra/src/main/java/org/apache/ignite/activestore/impl/kafka/KafkaIdSequencer.java	26
cassandra/src/main/java/org/apache/ignite/activestore/impl/kafka/KafkaIdSequencerFactory.java	18
cassandra/src/main/java/org/apache/ignite/activestore/impl/kv/KafkaProducers.java	5
cassandra/src/main/java/org/apache/ignite/activestore/impl/kv/MessageMetadata.java	41
cassandra/src/main/java/org/apache/ignite/activestore/impl/kv/MessageType.java	11
cassandra/src/main/java/org/apache/ignite/activestore/impl/kv/SnapshotAwareKeyValueReaderListener.java	30
cassandra/src/main/java/org/apache/ignite/activestore/impl/kv/TransactionalKafkaKVProvider.java	39
cassandra/src/main/java/org/apache/ignite/activestore/impl/kv/TransactionalKafkaProducer.java	60
cassandra/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/ConsumerDeployService.java	46
cassandra/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/DRDataCapturerBusConfiguration.java	23
cassandra/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/IgniteCommitter.java	32
cassandra/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/SubscriberConsumer.java	121
cassandra/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/TransactionWrapper.java	19
cassandra/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/Lead.java	101
cassandra/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadPlanner.java	114
cassandra/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/TxInfo.java	21
cassandra/src/main/java/org/apache/ignite/activestore/impl/util/ExportNameConventionUtil.java	23
cassandra/src/main/java/org/apache/ignite/activestore/impl/util/FileUtils.java	24
cassandra/src/main/java/org/apache/ignite/activestore/impl/util/MetadataAtomicsHelper.java	36
cassandra/src/main/java/org/apache/ignite/activestore/impl/util/PropertiesUtil.java	20
cassandra/src/main/java/org/apache/ignite/activestore/subscriber/Committer.java	11
cassandra/src/main/resources/cassandra.yaml	98
core/src/main/java/org/apache/ignite/activestore/ActiveCacheStore.java	155
core/src/main/java/org/apache/ignite/activestore/ClusterMode.java	4
core/src/main/java/org/apache/ignite/activestore/IdSequencer.java	5
core/src/main/java/org/apache/ignite/activestore/KeyValueListener.java	9
core/src/main/java/org/apache/ignite/activestore/SerializableProvider.java	5
core/src/main/java/org/apache/ignite/activestore/commons/ActiveStoreLifecycleService.java	27
core/src/main/java/org/apache/ignite/activestore/commons/BaseActiveStoreConfiguration.java	68
core/src/main/java/org/apache/ignite/activestore/commons/EndpointUtils.java	13
core/src/main/java/org/apache/ignite/activestore/commons/Lazy.java	49
core/src/main/java/org/apache/ignite/activestore/commons/ProxyService.java	22
core/src/main/java/org/apache/ignite/activestore/commons/Reference.java	6
core/src/main/java/org/apache/ignite/activestore/commons/UUIDFormat.java	7
core/src/main/java/org/apache/ignite/activestore/commons/injection/ActiveStoreIgniteCallable.java	9
core/src/main/java/org/apache/ignite/activestore/commons/injection/ActiveStoreIgniteRunnable.java	9
core/src/main/java/org/apache/ignite/activestore/commons/injection/ActiveStoreService.java	8
core/src/main/java/org/apache/ignite/activestore/commons/injection/DependencyContainer.java	67
core/src/main/java/org/apache/ignite/activestore/commons/injection/Injection.java	57
core/src/main/java/org/apache/ignite/activestore/commons/injection/LifecycleQueue.java	33
core/src/main/java/org/apache/ignite/activestore/commons/injection/ListOf.java	23
core/src/main/java/org/apache/ignite/activestore/commons/injection/PostCreationListener.java	43
core/src/main/java/org/apache/ignite/activestore/commons/retry/Retries.java	72
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryCallable.java	33
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryCallableAsyncOnCallback.java	26
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryFuture.java	54
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryRunnable.java	21
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryRunnableAsyncOnCallback.java	18
core/src/main/java/org/apache/ignite/activestore/commons/retry/RetryStrategy.java	74
core/src/main/java/org/apache/ignite/activestore/commons/serializer/JavaSerializer.java	13
core/src/main/java/org/apache/ignite/activestore/commons/serializer/Serializer.java	7
core/src/main/java/org/apache/ignite/activestore/commons/tasks/ExtendedScheduler.java	47
core/src/main/java/org/apache/ignite/activestore/commons/tasks/PeriodicCallTask.java	18
core/src/main/java/org/apache/ignite/activestore/commons/tasks/PeriodicTask.java	19
core/src/main/java/org/apache/ignite/activestore/commons/tasks/Scheduler.java	21
core/src/main/java/org/apache/ignite/activestore/commons/tasks/SimpleTask.java	11
core/src/main/java/org/apache/ignite/activestore/commons/tasks/Task.java	4
core/src/main/java/org/apache/ignite/activestore/impl/DataCapturerBusConfiguration.java	149
core/src/main/java/org/apache/ignite/activestore/impl/DataRecoveryConfig.java	44
core/src/main/java/org/apache/ignite/activestore/impl/InMemoryIdSequencer.java	13
core/src/main/java/org/apache/ignite/activestore/impl/config/EmptyFuture.java	31
core/src/main/java/org/apache/ignite/activestore/impl/config/FutureUnsubscribeOnFail.java	47
core/src/main/java/org/apache/ignite/activestore/impl/config/RPCManager.java	8
core/src/main/java/org/apache/ignite/activestore/impl/config/RPCManagerImpl.java	54
core/src/main/java/org/apache/ignite/activestore/impl/config/RPCService.java	4
core/src/main/java/org/apache/ignite/activestore/impl/config/RPCServiceImpl.java	95
core/src/main/java/org/apache/ignite/activestore/impl/config/RPCUpdater.java	6
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaConfig.java	55
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaMetadata.java	17
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaProducersManager.java	6
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaProducersManagerImpl.java	54
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaProducersManagerUpdater.java	105
core/src/main/java/org/apache/ignite/activestore/impl/config/ReplicaProducersUpdater.java	8
core/src/main/java/org/apache/ignite/activestore/impl/config/ResubscribeTask.java	19
core/src/main/java/org/apache/ignite/activestore/impl/config/SimpleSuperCluster.java	19
core/src/main/java/org/apache/ignite/activestore/impl/config/SuperCluster.java	11
core/src/main/java/org/apache/ignite/activestore/impl/config/UnsubscribeTask.java	15
core/src/main/java/org/apache/ignite/activestore/impl/config/UnsubscriberOnFailWrapper.java	7
core/src/main/java/org/apache/ignite/activestore/impl/config/UnsubscriberOnFailWrapperImpl.java	21
core/src/main/java/org/apache/ignite/activestore/impl/config/UpdateConfigurationTask.java	17
core/src/main/java/org/apache/ignite/activestore/impl/kafka/ConsumerProxyRetry.java	322
core/src/main/java/org/apache/ignite/activestore/impl/kafka/KafkaFactory.java	10
core/src/main/java/org/apache/ignite/activestore/impl/kafka/KafkaFactoryImpl.java	25
core/src/main/java/org/apache/ignite/activestore/impl/kafka/KafkaIdSequencer.java	57
core/src/main/java/org/apache/ignite/activestore/impl/kafka/KafkaIdSequencerFactory.java	19
core/src/main/java/org/apache/ignite/activestore/impl/kafka/ProducerProxyRetry.java	102
core/src/main/java/org/apache/ignite/activestore/impl/publisher/ActiveCacheStoreService.java	23
core/src/main/java/org/apache/ignite/activestore/impl/publisher/ActiveCacheStoreServiceImpl.java	37
core/src/main/java/org/apache/ignite/activestore/impl/publisher/AllReplicasRegisterTask.java	19
core/src/main/java/org/apache/ignite/activestore/impl/publisher/CommandServiceImpl.java	26
core/src/main/java/org/apache/ignite/activestore/impl/publisher/Commander.java	128
core/src/main/java/org/apache/ignite/activestore/impl/publisher/CommanderService.java	57
core/src/main/java/org/apache/ignite/activestore/impl/publisher/LocalKafkaKVListener.java	32
core/src/main/java/org/apache/ignite/activestore/impl/publisher/LocalKafkaProducer.java	43
core/src/main/java/org/apache/ignite/activestore/impl/publisher/LocalReconciliationWritersManager.java	60
core/src/main/java/org/apache/ignite/activestore/impl/publisher/PublisherKafkaService.java	39
core/src/main/java/org/apache/ignite/activestore/impl/publisher/PublisherReplicaService.java	41
core/src/main/java/org/apache/ignite/activestore/impl/publisher/PublisherUpdater.java	29
core/src/main/java/org/apache/ignite/activestore/impl/publisher/Reconciler.java	107
core/src/main/java/org/apache/ignite/activestore/impl/publisher/ReconciliationWriter.java	52
core/src/main/java/org/apache/ignite/activestore/impl/publisher/RegisterReplicaTask.java	23
core/src/main/java/org/apache/ignite/activestore/impl/publisher/RemoteKafkaProducer.java	51
core/src/main/java/org/apache/ignite/activestore/impl/publisher/Resubscriber.java	21
core/src/main/java/org/apache/ignite/activestore/impl/publisher/StartReconciliationTask.java	15
core/src/main/java/org/apache/ignite/activestore/impl/publisher/StopReconciliationTask.java	13
core/src/main/java/org/apache/ignite/activestore/impl/publisher/SynchronousPublisher.java	59
core/src/main/java/org/apache/ignite/activestore/impl/publisher/TransactionalKafkaProducer.java	43
core/src/main/java/org/apache/ignite/activestore/impl/publisher/UnsubscriptionNotificationTask.java	13
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/AbstractIgniteCommitter.java	33
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/BufferOverflowCondition.java	4
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/BufferOverflowConditionPeriodicTask.java	20
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/CommitOffsetsPeriodicTask.java	20
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/DeserializerClosure.java	25
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/DoneNotifier.java	20
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/FullCommitHandler.java	26
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/IgniteCommitter.java	24
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/KafkaHelper.java	20
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/LocalKafkaWriter.java	28
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/LoggingErrorHandler.java	13
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/OffsetCalculator.java	58
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/OffsetHolder.java	16
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/OnKafkaStop.java	21
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/ParallelIgniteCommitter.java	154
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/RebalanceListener.java	22
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/SimpleBufferOverflowCondition.java	11
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/SubscriberConsumer.java	175
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/SubscriberConsumerService.java	7
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/SubscriberConsumerServiceImpl.java	20
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/TransactionWrapper.java	43
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/TransactionsBuffer.java	83
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/consumer/TransactionsBufferHolder.java	8
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerMetadataRequest.java	16
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerPingCheckPeriodicTask.java	10
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerPingCheckStrategy.java	4
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerPingManager.java	61
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerResumeRequest.java	16
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ConsumerTask.java	18
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/DefaultConsumerPingCheckStrategy.java	14
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/DefaultGapDetectionStrategy.java	37
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/DenseCommittedIdSavePeriodicTask.java	13
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/DoneTask.java	21
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/GapDetectionStrategy.java	4
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/KafkaResurrectionCheckTask.java	42
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/Lead.java	230
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadContextLoader.java	104
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadPlanner.java	230
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadPlanningState.java	80
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadResponse.java	50
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadService.java	18
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadServiceImpl.java	46
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LeadServiceProxyRetry.java	114
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LoaderCurrentlyFinishedTask.java	13
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LocalLeadContextLoader.java	95
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/LocalLeadContextLoaderManager.java	48
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/MainHeartbeatPeriodicTask.java	42
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/MergeHelper.java	95
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/NotifyTask.java	30
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ReconciliationState.java	6
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/ReconciliationStateImpl.java	26
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/TestReconciliationState.java	14
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/TxInfo.java	26
core/src/main/java/org/apache/ignite/activestore/impl/subscriber/lead/UpdateInitialContextTask.java	16
core/src/main/java/org/apache/ignite/activestore/impl/transactions/JointTxScope.java	57
core/src/main/java/org/apache/ignite/activestore/impl/transactions/LinearTransactionDataIterator.java	35
core/src/main/java/org/apache/ignite/activestore/impl/transactions/LinearTransactionScopeIterator.java	30
core/src/main/java/org/apache/ignite/activestore/impl/transactions/TransactionMessage.java	10
core/src/main/java/org/apache/ignite/activestore/impl/transactions/TransactionMessageBuilder.java	24
core/src/main/java/org/apache/ignite/activestore/impl/transactions/TransactionMessageUtil.java	12
core/src/main/java/org/apache/ignite/activestore/impl/transactions/TransactionMetadata.java	23
core/src/main/java/org/apache/ignite/activestore/impl/transactions/TransactionMetadataBuilder.java	22
core/src/main/java/org/apache/ignite/activestore/impl/util/AtomicsHelper.java	46
core/src/main/java/org/apache/ignite/activestore/impl/util/ClusterGroupService.java	46
core/src/main/java/org/apache/ignite/activestore/impl/util/FileUtils.java	24
core/src/main/java/org/apache/ignite/activestore/impl/util/PropertiesUtil.java	13
core/src/main/java/org/apache/ignite/activestore/publisher/CommandService.java	10
core/src/main/java/org/apache/ignite/activestore/subscriber/Committer.java	9
core/src/main/java/org/apache/ignite/activestore/subscriber/TransactionSupplier.java	7
core/src/main/java/org/apache/ignite/activestore/transactions/TransactionDataIterator.java	4
core/src/main/java/org/apache/ignite/activestore/transactions/TransactionScopeIterator.java	8
lagerta-core/src/main/java/com/epam/lagerta/base/BlobValueTransformer.java	31
lagerta-core/src/main/java/com/epam/lagerta/base/EntityDescriptor.java	77
lagerta-core/src/main/java/com/epam/lagerta/base/EnumValueTransformer.java	28
lagerta-core/src/main/java/com/epam/lagerta/base/FieldDescriptor.java	24
lagerta-core/src/main/java/com/epam/lagerta/base/SimpleValueTransformer.java	70
lagerta-core/src/main/java/com/epam/lagerta/base/ValueTransformer.java	8
lagerta-core/src/main/java/com/epam/lagerta/base/jdbc/committer/JDBCCommitter.java	67
lagerta-core/src/main/java/com/epam/lagerta/base/util/FieldDescriptorHelper.java	59
lagerta-core/src/main/java/com/epam/lagerta/capturer/DataCapturerBus.java	130
lagerta-core/src/main/java/com/epam/lagerta/capturer/DataCapturerBusFactory.java	9
lagerta-core/src/main/java/com/epam/lagerta/capturer/DataCapturerLoader.java	7
lagerta-core/src/main/java/com/epam/lagerta/capturer/DefaultKeyTransformer.java	23
lagerta-core/src/main/java/com/epam/lagerta/capturer/DefaultValueTransformer.java	20
lagerta-core/src/main/java/com/epam/lagerta/capturer/IdSequencer.java	4
lagerta-core/src/main/java/com/epam/lagerta/capturer/JDBCDataCapturerLoader.java	69
lagerta-core/src/main/java/com/epam/lagerta/capturer/KeyTransformer.java	7
lagerta-core/src/main/java/com/epam/lagerta/capturer/ModificationListener.java	7
lagerta-core/src/main/java/com/epam/lagerta/capturer/SuspendableProducer.java	6
lagerta-core/src/main/java/com/epam/lagerta/capturer/SynchronousPublisher.java	33
lagerta-core/src/main/java/com/epam/lagerta/capturer/TransactionScope.java	22
lagerta-core/src/main/java/com/epam/lagerta/capturer/TransactionalProducer.java	10
lagerta-core/src/main/java/com/epam/lagerta/capturer/ValueTransformer.java	8
lagerta-core/src/main/java/com/epam/lagerta/common/CallableKeyListTask.java	12
lagerta-core/src/main/java/com/epam/lagerta/common/CallableKeyTask.java	22
lagerta-core/src/main/java/com/epam/lagerta/common/CallableTask.java	22
lagerta-core/src/main/java/com/epam/lagerta/common/PeriodicRule.java	33
lagerta-core/src/main/java/com/epam/lagerta/common/PredicateRule.java	27
lagerta-core/src/main/java/com/epam/lagerta/common/Scheduler.java	46
lagerta-core/src/main/java/com/epam/lagerta/common/ToMapCollector.java	49
lagerta-core/src/main/java/com/epam/lagerta/common/TripleFunction.java	11
lagerta-core/src/main/java/com/epam/lagerta/kafka/KafkaFactory.java	8
lagerta-core/src/main/java/com/epam/lagerta/kafka/KafkaFactoryImpl.java	16
lagerta-core/src/main/java/com/epam/lagerta/kafka/KafkaIdSequencer.java	29
lagerta-core/src/main/java/com/epam/lagerta/kafka/KafkaLogCommitter.java	8
lagerta-core/src/main/java/com/epam/lagerta/kafka/KafkaLogCommitterImpl.java	25
lagerta-core/src/main/java/com/epam/lagerta/kafka/ProducersManager.java	84
lagerta-core/src/main/java/com/epam/lagerta/kafka/SuspendableKafkaProducerImpl.java	46
lagerta-core/src/main/java/com/epam/lagerta/kafka/SuspendingFuture.java	45
lagerta-core/src/main/java/com/epam/lagerta/kafka/TransactionalKafkaProducerImpl.java	54
lagerta-core/src/main/java/com/epam/lagerta/kafka/config/BasicTopicConfig.java	18
lagerta-core/src/main/java/com/epam/lagerta/kafka/config/ClusterConfig.java	35
lagerta-core/src/main/java/com/epam/lagerta/kafka/config/KafkaConfig.java	26
lagerta-core/src/main/java/com/epam/lagerta/kafka/config/SubscriberConfig.java	38
lagerta-core/src/main/java/com/epam/lagerta/services/LeadService.java	12
lagerta-core/src/main/java/com/epam/lagerta/services/LeadServiceImpl.java	50
lagerta-core/src/main/java/com/epam/lagerta/services/ReaderService.java	6
lagerta-core/src/main/java/com/epam/lagerta/services/ReaderServiceImpl.java	33
lagerta-core/src/main/java/com/epam/lagerta/subscriber/CommitServitor.java	45
lagerta-core/src/main/java/com/epam/lagerta/subscriber/CommitStrategy.java	6
lagerta-core/src/main/java/com/epam/lagerta/subscriber/CommittedOffset.java	48
lagerta-core/src/main/java/com/epam/lagerta/subscriber/Committer.java	6
lagerta-core/src/main/java/com/epam/lagerta/subscriber/ParallelCommitStrategy.java	164
lagerta-core/src/main/java/com/epam/lagerta/subscriber/PeriodicIterationCondition.java	13
lagerta-core/src/main/java/com/epam/lagerta/subscriber/Reader.java	182
lagerta-core/src/main/java/com/epam/lagerta/subscriber/ReaderConfig.java	46
lagerta-core/src/main/java/com/epam/lagerta/subscriber/ReaderRebalanceListener.java	22
lagerta-core/src/main/java/com/epam/lagerta/subscriber/ReaderTxScope.java	43
lagerta-core/src/main/java/com/epam/lagerta/subscriber/SequentialCommitStrategy.java	19
lagerta-core/src/main/java/com/epam/lagerta/subscriber/SimpleBufferOverflowCondition.java	13
lagerta-core/src/main/java/com/epam/lagerta/subscriber/TransactionData.java	28
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/CommittedTransactions.java	65
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/DefaultGapDetectionStrategy.java	16
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/GapDetectionStrategy.java	5
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/Heartbeats.java	27
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/Lead.java	14
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/LeadImpl.java	129
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/LeadStateAssistant.java	5
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/LeadStateAssistantImpl.java	67
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/LeadStateLoader.java	144
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/ReadTransactions.java	209
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/Reconciler.java	6
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/ReconcilerImpl.java	130
lagerta-core/src/main/java/com/epam/lagerta/subscriber/lead/RuleTimeouts.java	26
lagerta-core/src/main/java/com/epam/lagerta/subscriber/util/MergeUtil.java	67
lagerta-core/src/main/java/com/epam/lagerta/subscriber/util/PlannerUtil.java	72
lagerta-core/src/main/java/com/epam/lagerta/util/Atomic.java	6
lagerta-core/src/main/java/com/epam/lagerta/util/AtomicsHelper.java	51
lagerta-core/src/main/java/com/epam/lagerta/util/JDBCKeyValueMapper.java	118
lagerta-core/src/main/java/com/epam/lagerta/util/Serializer.java	6
lagerta-core/src/main/java/com/epam/lagerta/util/SerializerImpl.java	14
lagerta-core/src/main/java/com/epam/lagerta/util/TransactionPartitionUtil.java	6
lagerta-jepsen/project.clj	8
lagerta-jepsen/src/jepsen/lagerta/core.clj	10
lagerta-jmh/src/main/java/com/epam/lagerta/jmh/AbstractPlannerUtilPerformance.java	40
lagerta-jmh/src/main/java/com/epam/lagerta/jmh/PlannerUtilPerformanceCases.java	80
lagerta-jmh/src/main/java/com/epam/lagerta/jmh/utils/DataUtil.java	50
lagerta-jmh/src/main/java/com/epam/lagerta/jmh/utils/IdGenerator.java	22
lagerta-jmh/src/main/java/com/epam/lagerta/jmh/utils/TransactionGenerator.java	12
lagerta-test/src/main/java/com/epam/lagerta/base/jdbc/H2HikariDataSource.java	21
lagerta-test/src/main/java/com/epam/lagerta/cluster/IgniteClusterManager.java	10
lagerta-test/src/main/java/com/epam/lagerta/cluster/IgniteConfigHelper.java	26
lagerta-test/src/main/java/com/epam/lagerta/resources/DBResource.java	39
lagerta-test/src/main/java/com/epam/lagerta/resources/EmbeddedKafka.java	89
lagerta-test/src/main/java/com/epam/lagerta/resources/H2DataBaseServer.java	17
lagerta-test/src/main/java/com/epam/lagerta/resources/IgniteClusterResource.java	35
lagerta-test/src/main/java/com/epam/lagerta/resources/Resource.java	5
lagerta-test/src/main/java/com/epam/lagerta/resources/TemporaryDirectory.java	30
tools/logback-travis.xml	23