Code Review / dcaegen2 / services.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: d564502) | patch
Dynamically detect topic updates and new topics 16/88516/1
authorGuobiao Mo <guobiaomo@chinamobile.com>
Mon, 27 May 2019 06:08:21 +0000 (23:08 -0700)
committerGuobiao Mo <guobiaomo@chinamobile.com>
Mon, 27 May 2019 06:08:21 +0000 (23:08 -0700)
commitaa70d5683655fd13d476441c056c877f76796a7c
treeefb8994c328e0f0c9fe0c1627be64366f84b4f03tree | snapshot
parentd564502aa81ecc64432c6afbd5c18a18bfad9c6bcommit | diff
Dynamically detect topic updates and new topics

Issue-ID: DCAEGEN2-1195
Change-Id: I35d36a9aafe3a7681a9d4745bc509aded111b29d
Signed-off-by: Guobiao Mo <guobiaomo@chinamobile.com>
17 files changed:
components/datalake-handler/feeder/src/assembly/scripts/init_db.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/enumeration/DataFormat.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/CouchbaseService.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/ElasticsearchService.java diff | blob | history
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/HdfsService.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 [moved from components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/service/PullThread.java with 60% similarity] 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 [new file with mode: 0644] blob
components/datalake-handler/feeder/src/main/java/org/onap/datalake/feeder/util/Util.java diff | blob | history
components/datalake-handler/feeder/src/main/resources/application.properties 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/FeederControllerTest.java diff | blob | history
components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/PullServiceTest.java diff | blob | history
components/datalake-handler/feeder/src/test/resources/application.properties diff | blob | history