gerrit.onap Code Review - dcaegen2/services.git/commit

Code Review / dcaegen2 / services.git / commit

author	Guobiao Mo <guobiaomo@chinamobile.com>
	Fri, 28 Jun 2019 01:42:59 +0000 (18:42 -0700)
committer	Guobiao Mo <guobiaomo@chinamobile.com>
	Fri, 28 Jun 2019 01:46:11 +0000 (18:46 -0700)
commit	b14c5766902d486a94a8db96d2a31ff0e9e8255e
tree	421f9bd6ac50f36d5f128bfab7fd3653b9ff8894	tree \| snapshot
parent	b3f5051484f5b973a47a60fb8f76a67ca5ff88da	commit \| diff

supports multiple Kafka clusters and DBs

Read data from Kafka and store into DBs

Issue-ID: DCAEGEN2-1631

Change-Id: Ic2736b6e0497ac2084b1a7ce0da3a6e0e1379f43
Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>

52 files changed:

components/datalake-handler/feeder/src/assembly/scripts/init_db.sql		diff \| blob \| history
components/datalake-handler/feeder/src/assembly/scripts/init_db_data.sql		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/config/ApplicationConfiguration.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/DbController.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/controller/TopicController.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Db.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/DbType.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/EffectiveTopic.java	[new file with mode: 0644]	blob
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Kafka.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/domain/Topic.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/dto/DbConfig.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/dto/TopicConfig.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/enumeration/DbTypeEnum.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/enumeration/DesignTypeEnum.java	[moved from components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/enumeration/DbTypeEnumTest.java with 68% similarity]	diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/repository/TopicNameRepository.java	[new file with mode: 0644]	blob
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/repository/TopicRepository.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DbService.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/DmaapService.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/PortalDesignService.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/PullService.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/Puller.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/StoreService.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/TopicConfigPollingService.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/TopicService.java		diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/CouchbaseService.java	[moved from components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/CouchbaseService.java with 88% similarity]	diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/DbStoreService.java	[new file with mode: 0644]	blob
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/ElasticsearchService.java	[moved from components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/ElasticsearchService.java with 87% similarity]	diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/HdfsService.java	[moved from components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.java with 83% similarity]	diff \| blob \| history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/db/MongodbService.java	[moved from components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/MongodbService.java with 88% similarity]	diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/config/ApplicationConfigurationTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/controller/DbControllerTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/controller/PortalControllerTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/controller/PortalDesignControllerTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/controller/TopicControllerTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/domain/DbTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/domain/PortalDesignTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/domain/PortalTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/domain/TopicTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/PortalConfigTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/dto/TopicConfigTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/DbServiceTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/DmaapServiceTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/PullerTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/StoreServiceTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/TopicConfigPollingServiceTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/TopicServiceTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/db/CouchbaseServiceTest.java	[moved from components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/CouchbaseServiceTest.java with 90% similarity]	diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/db/ElasticsearchServiceTest.java	[moved from components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/ElasticsearchServiceTest.java with 94% similarity]	diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/db/HdfsServiceTest.java	[moved from components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/HdfsServiceTest.java with 90% similarity]	diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/db/MongodbServiceTest.java	[moved from components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/MongodbServiceTest.java with 92% similarity]	diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/util/DruidSupervisorGeneratorTest.java		diff \| blob \| history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/util/TestUtil.java	[new file with mode: 0644]	blob

RSS Atom