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