refactor arch Author: William Guo <[email protected]>
Closes #16 from guoyuepeng/master. Project: http://git-wip-us.apache.org/repos/asf/incubator-griffin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-griffin/commit/f629d0f4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-griffin/tree/f629d0f4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-griffin/diff/f629d0f4 Branch: refs/heads/master Commit: f629d0f40045ffab2f9bbe767c8122e1e68fb124 Parents: 1dcad96 Author: William Guo <[email protected]> Authored: Thu May 4 11:03:42 2017 +0800 Committer: William Guo <[email protected]> Committed: Thu May 4 11:03:42 2017 +0800 ---------------------------------------------------------------------- .gitignore | 6 + griffin-core/.gitignore | 27 - griffin-core/pom.xml | 302 - .../com/ebay/oss/griffin/common/HDFSUtils.java | 33 - .../ebay/oss/griffin/common/NumberUtils.java | 41 - .../java/com/ebay/oss/griffin/common/Pair.java | 64 - .../griffin/common/ScheduleModelSeperator.java | 21 - .../oss/griffin/common/SimpleCORSFilter.java | 45 - .../ebay/oss/griffin/domain/AnomalyType.java | 26 - .../com/ebay/oss/griffin/domain/DataAsset.java | 199 - .../com/ebay/oss/griffin/domain/DataSchema.java | 80 - .../java/com/ebay/oss/griffin/domain/DqJob.java | 121 - .../ebay/oss/griffin/domain/DqMetricsValue.java | 111 - .../com/ebay/oss/griffin/domain/DqModel.java | 231 - .../com/ebay/oss/griffin/domain/DqSchedule.java | 123 - .../com/ebay/oss/griffin/domain/IdEntity.java | 28 - .../com/ebay/oss/griffin/domain/JobStatus.java | 24 - .../com/ebay/oss/griffin/domain/MetricType.java | 25 - .../ebay/oss/griffin/domain/ModelStatus.java | 24 - .../com/ebay/oss/griffin/domain/ModelType.java | 24 - .../oss/griffin/domain/PartitionFormat.java | 59 - .../oss/griffin/domain/SampleFilePathLKP.java | 56 - .../ebay/oss/griffin/domain/ScheduleType.java | 24 - .../com/ebay/oss/griffin/domain/SystemType.java | 69 - .../oss/griffin/domain/UserSubscription.java | 101 - .../ebay/oss/griffin/domain/ValidityType.java | 31 - .../griffin/error/BarkDbOperationException.java | 105 - .../oss/griffin/error/BarkWebException.java | 136 - .../griffin/error/BarkWebExceptionMapper.java | 43 - .../ebay/oss/griffin/error/ErrorMessage.java | 101 - .../com/ebay/oss/griffin/repo/BarkIdRepo.java | 11 - .../com/ebay/oss/griffin/repo/BarkRepo.java | 31 - .../com/ebay/oss/griffin/repo/BaseIdRepo.java | 53 - .../com/ebay/oss/griffin/repo/BaseRepo.java | 95 - .../ebay/oss/griffin/repo/DataAssetRepo.java | 26 - .../oss/griffin/repo/DataAssetRepoImpl.java | 47 - .../com/ebay/oss/griffin/repo/DqJobRepo.java | 33 - .../ebay/oss/griffin/repo/DqJobRepoImpl.java | 102 - .../ebay/oss/griffin/repo/DqMetricsRepo.java | 31 - .../oss/griffin/repo/DqMetricsRepoImpl.java | 85 - .../com/ebay/oss/griffin/repo/DqModelRepo.java | 40 - .../ebay/oss/griffin/repo/DqModelRepoImpl.java | 162 - .../ebay/oss/griffin/repo/DqScheduleRepo.java | 33 - .../oss/griffin/repo/DqScheudleRepoImpl.java | 82 - .../oss/griffin/repo/SampleFilePathRepo.java | 27 - .../griffin/repo/SampleFilePathRepoImpl.java | 43 - .../com/ebay/oss/griffin/repo/SequenceRepo.java | 22 - .../ebay/oss/griffin/repo/SequenceRepoImpl.java | 44 - .../oss/griffin/repo/UserSubscriptionRepo.java | 26 - .../griffin/repo/UserSubscriptionRepoImpl.java | 60 - .../griffin/resources/DQMetricsController.java | 253 - .../griffin/resources/DQModelController.java | 113 - .../griffin/resources/DataAssetController.java | 164 - .../oss/griffin/resources/LoginController.java | 56 - .../resources/NotificationController.java | 44 - .../griffin/resources/ScheduleController.java | 39 - .../griffin/resources/SubscribeController.java | 55 - .../com/ebay/oss/griffin/service/Converter.java | 23 - .../oss/griffin/service/DQMetricsService.java | 59 - .../griffin/service/DQMetricsServiceImpl.java | 321 - .../oss/griffin/service/DataAssetService.java | 36 - .../griffin/service/DataAssetServiceImpl.java | 363 - .../oss/griffin/service/DqModelConverter.java | 52 - .../oss/griffin/service/DqModelCreator.java | 32 - .../oss/griffin/service/DqModelService.java | 45 - .../oss/griffin/service/DqModelServiceImpl.java | 181 - .../oss/griffin/service/DqScheduleService.java | 27 - .../griffin/service/DqScheduleServiceImpl.java | 670 - .../oss/griffin/service/DummyLoginService.java | 25 - .../ebay/oss/griffin/service/LoginService.java | 21 - .../griffin/service/ModelInputConverter.java | 80 - .../griffin/service/NotificationService.java | 29 - .../service/NotificationServiceImpl.java | 82 - .../ebay/oss/griffin/service/RefMetrcsCalc.java | 23 - .../oss/griffin/service/RefMetricsCalcImpl.java | 347 - .../oss/griffin/service/SubscribeService.java | 26 - .../griffin/service/SubscribeServiceImpl.java | 43 - .../modelcreator/AccurcyModelCreator.java | 45 - .../modelcreator/AnomalyModelCreator.java | 32 - .../service/modelcreator/BaseModelCreator.java | 157 - .../modelcreator/DqModelCreatorChain.java | 35 - .../modelcreator/PublishModelCreator.java | 29 - .../modelcreator/ValidityModelCreator.java | 36 - .../oss/griffin/vo/AccuracyHiveJobConfig.java | 79 - .../griffin/vo/AccuracyHiveJobConfigDetail.java | 87 - .../ebay/oss/griffin/vo/AssetLevelMetrics.java | 136 - .../oss/griffin/vo/AssetLevelMetricsDetail.java | 125 - .../java/com/ebay/oss/griffin/vo/BaseObj.java | 50 - .../oss/griffin/vo/BollingerBandsEntity.java | 61 - .../com/ebay/oss/griffin/vo/DQHealthStats.java | 43 - .../com/ebay/oss/griffin/vo/DataAssetIndex.java | 43 - .../com/ebay/oss/griffin/vo/DataAssetInput.java | 109 - .../java/com/ebay/oss/griffin/vo/DqModelVo.java | 95 - .../java/com/ebay/oss/griffin/vo/LoginUser.java | 50 - .../java/com/ebay/oss/griffin/vo/MADEntity.java | 44 - .../ebay/oss/griffin/vo/MappingItemInput.java | 60 - .../ebay/oss/griffin/vo/ModelBasicInputNew.java | 131 - .../ebay/oss/griffin/vo/ModelExtraInputNew.java | 68 - .../com/ebay/oss/griffin/vo/ModelInput.java | 99 - .../ebay/oss/griffin/vo/NotificationRecord.java | 102 - .../ebay/oss/griffin/vo/OverViewStatistics.java | 44 - .../ebay/oss/griffin/vo/PartitionConfig.java | 41 - .../ebay/oss/griffin/vo/PlatformMetadata.java | 52 - .../oss/griffin/vo/PlatformSubscription.java | 58 - .../java/com/ebay/oss/griffin/vo/SampleOut.java | 36 - .../ebay/oss/griffin/vo/SystemLevelMetrics.java | 66 - .../oss/griffin/vo/SystemLevelMetricsList.java | 371 - .../com/ebay/oss/griffin/vo/SystemMetadata.java | 52 - .../ebay/oss/griffin/vo/SystemSubscription.java | 58 - .../oss/griffin/vo/ValidateHiveJobConfig.java | 99 - .../vo/ValidateHiveJobConfigLv1Detail.java | 59 - .../vo/ValidateHiveJobConfigLv2Detail.java | 52 - .../src/main/resources/application.properties | 36 - .../src/main/resources/log4j.properties | 5 - .../src/main/webapp/WEB-INF/spring/context.xml | 49 - .../webapp/WEB-INF/spring/static-context.xml | 25 - griffin-core/src/main/webapp/WEB-INF/web.xml | 77 - .../webapp/WEB-INF/webres/resource.properties | 0 .../oss/griffin/common/CommonResourceTest.java | 34 - .../oss/griffin/domain/DomainResourceTest.java | 255 - .../ebay/oss/griffin/domain/SystemTypeTest.java | 29 - .../oss/griffin/resources/ControllersTest.java | 524 - .../service/DQMetricsServiceImplTest.java | 206 - .../griffin/service/DataAssetServiceTest.java | 168 - .../griffin/service/DqModelConverterTest.java | 19 - .../oss/griffin/service/DqModelServiceTest.java | 213 - .../griffin/service/DqScheduleServiceTest.java | 24 - .../oss/griffin/service/LoginServiceTest.java | 34 - .../service/NotificationServiceImplTest.java | 110 - .../griffin/service/RefMetricsCalcImplTest.java | 65 - .../service/SubscribeServiceImplTest.java | 57 - .../com/ebay/oss/griffin/vo/VoResourceTest.java | 651 - .../src/test/resources/application.properties | 31 - griffin-core/src/test/resources/context.xml | 30 - griffin-models/.gitignore | 43 - griffin-models/README.md | 158 - griffin-models/accu_config.json | 62 - griffin-models/app.conf.template | 4 - griffin-models/data/test/dataFile/srcFile.avro | Bin 382 -> 0 bytes griffin-models/data/test/dataFile/srcFile.avsc | 18 - griffin-models/data/test/dataFile/srcFile.json | 5 - griffin-models/data/test/dataFile/srcFileCsv | 6 - .../data/test/dataFile/srcFileCsv_type | 5 - griffin-models/data/test/dataFile/tgtFile.avro | Bin 374 -> 0 bytes griffin-models/data/test/dataFile/tgtFile.avsc | 18 - griffin-models/data/test/dataFile/tgtFile.json | 5 - griffin-models/data/test/dataFile/tgtFileCsv | 6 - .../data/test/dataFile/tgtFileCsv_type | 5 - .../data/test/recordFile/_RESULT_ACCU | 5 - .../data/test/recordFile/_RESULT_VALI | 3 - .../data/test/reqJson/accuAvroTest.json | 34 - .../data/test/reqJson/accuCsvTest.json | 34 - .../data/test/reqJson/valiAvroTest.json | 83 - .../data/test/reqJson/valiCsvTest.json | 83 - griffin-models/pom.xml | 201 - .../org/apache/griffin/accuracy/Accu.scala | 195 - .../griffin/accuracy/AccuracyConfEntity.scala | 17 - .../griffin/accuracy/AccuracyMapping.scala | 21 - .../apache/griffin/common/PartitionPair.scala | 3 - .../dataLoaderUtils/AvroFileDataLoader.scala | 27 - .../dataLoaderUtils/CsvFileDataLoader.scala | 45 - .../griffin/dataLoaderUtils/DataLoader.scala | 11 - .../dataLoaderUtils/DataLoaderFactory.scala | 18 - .../dataLoaderUtils/FileLoaderUtil.scala | 7 - .../dataLoaderUtils/HiveDataLoader.scala | 20 - .../main/scala/org/apache/griffin/package.scala | 9 - .../org/apache/griffin/util/DataTypeUtils.scala | 146 - .../org/apache/griffin/util/HdfsUtils.scala | 27 - .../apache/griffin/util/PartitionUtils.scala | 31 - .../apache/griffin/validility/MetricsType.scala | 16 - .../org/apache/griffin/validility/Vali.scala | 211 - .../griffin/validility/ValidityConfEntity.scala | 17 - .../apache/griffin/validility/ValidityReq.scala | 22 - .../src/test/scala/modelTest/AccuTest.scala | 86 - .../src/test/scala/modelTest/ValiTest.scala | 80 - .../src/test/scala/samples/junit.scala | 17 - .../src/test/scala/samples/scalatest.scala | 109 - .../src/test/scala/samples/specs.scala | 31 - griffin-models/vali_config.json | 131 - griffin-scheduler/pom.xml | 83 - .../apache/bark/scheduler/BarkScheduler.java | 11 - .../bark/scheduler/BarkSchedulerTest.java | 13 - griffin-ui/.gitignore | 6 - griffin-ui/apidocs/bark.json | 737 - griffin-ui/apidocs/css/print.css | 1187 - griffin-ui/apidocs/css/reset.css | 125 - griffin-ui/apidocs/css/screen.css | 1300 - griffin-ui/apidocs/css/style.css | 250 - griffin-ui/apidocs/css/typography.css | 14 - griffin-ui/apidocs/example/anomaly.json | 19 - griffin-ui/apidocs/example/publish.json | 17 - griffin-ui/apidocs/example/validity.json | 20 - griffin-ui/apidocs/fonts/DroidSans-Bold.ttf | Bin 42480 -> 0 bytes griffin-ui/apidocs/fonts/DroidSans.ttf | Bin 41028 -> 0 bytes griffin-ui/apidocs/images/collapse.gif | Bin 69 -> 0 bytes griffin-ui/apidocs/images/expand.gif | Bin 73 -> 0 bytes griffin-ui/apidocs/images/explorer_icons.png | Bin 5763 -> 0 bytes griffin-ui/apidocs/images/favicon-16x16.png | Bin 645 -> 0 bytes griffin-ui/apidocs/images/favicon-32x32.png | Bin 1654 -> 0 bytes griffin-ui/apidocs/images/favicon.ico | Bin 5430 -> 0 bytes griffin-ui/apidocs/images/logo_small.png | Bin 770 -> 0 bytes griffin-ui/apidocs/images/pet_store_api.png | Bin 824 -> 0 bytes griffin-ui/apidocs/images/throbber.gif | Bin 9257 -> 0 bytes griffin-ui/apidocs/images/wordnik_api.png | Bin 980 -> 0 bytes griffin-ui/apidocs/index.html | 125 - griffin-ui/apidocs/lang/en.js | 55 - griffin-ui/apidocs/lang/es.js | 52 - griffin-ui/apidocs/lang/fr.js | 53 - griffin-ui/apidocs/lang/it.js | 52 - griffin-ui/apidocs/lang/ja.js | 53 - griffin-ui/apidocs/lang/pl.js | 53 - griffin-ui/apidocs/lang/pt.js | 53 - griffin-ui/apidocs/lang/ru.js | 55 - griffin-ui/apidocs/lang/tr.js | 53 - griffin-ui/apidocs/lang/translator.js | 39 - griffin-ui/apidocs/lang/zh-cn.js | 53 - griffin-ui/apidocs/lib/backbone-min.js | 15 - griffin-ui/apidocs/lib/handlebars-2.0.0.js | 28 - griffin-ui/apidocs/lib/highlight.7.3.pack.js | 1 - griffin-ui/apidocs/lib/jquery-1.8.0.min.js | 2 - griffin-ui/apidocs/lib/jquery.ba-bbq.min.js | 18 - griffin-ui/apidocs/lib/jquery.slideto.min.js | 1 - griffin-ui/apidocs/lib/jquery.wiggle.min.js | 8 - griffin-ui/apidocs/lib/jsoneditor.min.js | 11 - griffin-ui/apidocs/lib/marked.js | 1272 - griffin-ui/apidocs/lib/swagger-oauth.js | 338 - griffin-ui/apidocs/lib/underscore-min.js | 6 - griffin-ui/apidocs/lib/underscore-min.map | 1 - griffin-ui/apidocs/o2c.html | 20 - griffin-ui/apidocs/pet_example.json | 426 - griffin-ui/apidocs/sample.json | 83 - griffin-ui/apidocs/swagger-ui.js | 26330 ------- griffin-ui/apidocs/swagger-ui.min.js | 11 - griffin-ui/apidocs/swagger.json | 1633 - griffin-ui/bower.json | 19 - .../AngularJS-Toaster/toaster.css | 240 - .../AngularJS-Toaster/toaster.js | 504 - .../AngularJS-Toaster/toaster.min.css | 12 - .../AngularJS-Toaster/toaster.min.js | 13 - .../angular-animate/angular-animate.js | 4139 -- .../angular-animate/angular-animate.min.js | 57 - .../angular-cookies/angular-cookies.js | 322 - .../angular-cookies/angular-cookies.min.js | 9 - .../angular-route/angular-route.js | 1069 - .../angular-route/angular-route.min.js | 16 - .../angular-smart-table/dist/smart-table.js | 539 - .../angular-smart-table/dist/smart-table.min.js | 6 - .../angular-spinner/angular-spinner.js | 137 - .../angular-spinner/angular-spinner.min.js | 2 - .../bower_components/angular/angular-csp.css | 21 - griffin-ui/bower_components/angular/angular.js | 31768 --------- .../bower_components/angular/angular.min.js | 318 - .../bootstrap/dist/js/bootstrap.js | 2377 - .../bootstrap/dist/js/bootstrap.min.js | 7 - .../bootswatch/cyborg/bootstrap.css | 6929 -- .../bootswatch/cyborg/bootstrap.min.css | 11 - .../fonts/glyphicons-halflings-regular.eot | Bin 20127 -> 0 bytes .../fonts/glyphicons-halflings-regular.svg | 288 - .../fonts/glyphicons-halflings-regular.ttf | Bin 45404 -> 0 bytes .../fonts/glyphicons-halflings-regular.woff | Bin 23424 -> 0 bytes .../fonts/glyphicons-halflings-regular.woff2 | Bin 18028 -> 0 bytes .../bower_components/domReady/domReady.js | 129 - .../bower_components/echarts/dist/echarts.js | 63245 ----------------- .../echarts/dist/echarts.min.js | 35 - .../bower_components/echarts/theme/dark.js | 152 - .../font-awesome/css/font-awesome.css | 2086 - .../font-awesome/css/font-awesome.min.css | 4 - .../font-awesome/fonts/FontAwesome.otf | Bin 109688 -> 0 bytes .../font-awesome/fonts/fontawesome-webfont.eot | Bin 70807 -> 0 bytes .../font-awesome/fonts/fontawesome-webfont.svg | 655 - .../font-awesome/fonts/fontawesome-webfont.ttf | Bin 142072 -> 0 bytes .../font-awesome/fonts/fontawesome-webfont.woff | Bin 83588 -> 0 bytes .../fonts/fontawesome-webfont.woff2 | Bin 66624 -> 0 bytes .../bower_components/jquery/dist/jquery.js | 9210 --- .../bower_components/jquery/dist/jquery.min.js | 5 - .../bower_components/requirejs/require.js | 2129 - griffin-ui/bower_components/spin.js/spin.js | 377 - griffin-ui/bower_components/spin.js/spin.min.js | 2 - griffin-ui/build.xml | 28 - griffin-ui/css/main.css | 1053 - griffin-ui/css/sidebar.css | 179 - griffin-ui/css/treeview-check.css | 81 - griffin-ui/css/treeview.css | 81 - griffin-ui/img/1.PNG | Bin 13855 -> 0 bytes griffin-ui/img/2.PNG | Bin 8562 -> 0 bytes griffin-ui/img/bollinger.png | Bin 145323 -> 0 bytes griffin-ui/img/construction.gif | Bin 4853 -> 0 bytes griffin-ui/img/favicon.ico | Bin 9920 -> 0 bytes griffin-ui/img/logo.gif | Bin 5764 -> 0 bytes griffin-ui/img/mad.png | Bin 47922 -> 0 bytes griffin-ui/img/sidebar1.png | Bin 1536 -> 0 bytes griffin-ui/img/sidebar2.png | Bin 1617 -> 0 bytes griffin-ui/img/yoy.png | Bin 28400 -> 0 bytes griffin-ui/index.html | 185 - griffin-ui/js/app.js | 42 - griffin-ui/js/bs.js | 31 - griffin-ui/js/controllers/bigChart-ctrl.js | 58 - .../js/controllers/createdataasset-ctrl.js | 180 - griffin-ui/js/controllers/createrule-ac-ctrl.js | 494 - griffin-ui/js/controllers/createrule-an-ctrl.js | 298 - griffin-ui/js/controllers/createrule-pu-ctrl.js | 161 - griffin-ui/js/controllers/createrule-va-ctrl.js | 331 - griffin-ui/js/controllers/createrule0-ctrl.js | 41 - griffin-ui/js/controllers/dataassets-ctrl.js | 124 - .../js/controllers/downloadSample-ctrl.js | 36 - griffin-ui/js/controllers/editdataasset-ctrl.js | 213 - griffin-ui/js/controllers/footer-ctrl.js | 56 - griffin-ui/js/controllers/health-ctrl.js | 191 - griffin-ui/js/controllers/index.js | 40 - griffin-ui/js/controllers/main-ctrl.js | 36 - griffin-ui/js/controllers/metrics-ctrl.js | 180 - griffin-ui/js/controllers/module.js | 18 - griffin-ui/js/controllers/mydashboard-ctrl.js | 84 - griffin-ui/js/controllers/nav-ctrl.js | 65 - griffin-ui/js/controllers/rule-ctrl.js | 174 - griffin-ui/js/controllers/sidebar-ctrl.js | 139 - .../js/controllers/subscribemodel-ctrl.js | 406 - griffin-ui/js/controllers/viewrule-ctrl.js | 87 - griffin-ui/js/directives/bigchart.js | 92 - griffin-ui/js/directives/index.js | 15 - griffin-ui/js/directives/module.js | 18 - griffin-ui/js/directives/treeview.js | 252 - griffin-ui/js/filters/index.js | 15 - griffin-ui/js/filters/module.js | 20 - griffin-ui/js/filters/strmap.js | 66 - griffin-ui/js/filters/strshorten.js | 45 - griffin-ui/js/main.js | 88 - griffin-ui/js/routes.js | 221 - griffin-ui/js/services/bark-chart.js | 613 - griffin-ui/js/services/index.js | 15 - griffin-ui/js/services/module.js | 18 - griffin-ui/js/services/services.js | 100 - griffin-ui/login/b3vHigh.jpg | Bin 555201 -> 0 bytes griffin-ui/login/background.jpg | Bin 225253 -> 0 bytes griffin-ui/login/login.css | 87 - griffin-ui/login/login.html | 116 - griffin-ui/login/login.js | 108 - griffin-ui/login/logo.gif | Bin 59985 -> 0 bytes griffin-ui/login/pad.png | Bin 140342 -> 0 bytes griffin-ui/package.json | 27 - .../dataassets/confirmation-dataasset.html | 120 - .../confirmation-delete-dataasset.html | 100 - .../pages/dataassets/createdataasset.html | 237 - griffin-ui/pages/dataassets/dataassets.html | 112 - griffin-ui/pages/dataassets/editdataasset.html | 219 - griffin-ui/pages/health/health.html | 39 - griffin-ui/pages/metrics/dashboard.html | 59 - griffin-ui/pages/metrics/download-sample.html | 48 - griffin-ui/pages/metrics/metrics.css | 22 - .../mydashboard/confirmation-subscribe.html | 38 - griffin-ui/pages/mydashboard/mydashboard.html | 44 - .../pages/mydashboard/subscribemodel.html | 114 - griffin-ui/pages/rules/confirmation-ac.html | 167 - griffin-ui/pages/rules/confirmation-an.html | 143 - griffin-ui/pages/rules/confirmation-pu.html | 157 - griffin-ui/pages/rules/confirmation-va.html | 157 - griffin-ui/pages/rules/createrule-ac.html | 505 - griffin-ui/pages/rules/createrule-an.html | 406 - griffin-ui/pages/rules/createrule-pu.html | 232 - griffin-ui/pages/rules/createrule-va.html | 403 - griffin-ui/pages/rules/createrule0.html | 251 - griffin-ui/pages/rules/delete-confirm.html | 121 - griffin-ui/pages/rules/rule.css | 341 - griffin-ui/pages/rules/rules.html | 104 - griffin-ui/pages/rules/va-explaination.html | 767 - griffin-ui/pages/rules/viewrule.html | 325 - griffin-ui/pages/template/bigchart.css | 89 - griffin-ui/pages/template/bigchart.html | 31 - griffin-ui/pages/template/undercons.html | 18 - griffin-ui/pom.xml | 70 - griffin-ui/sidebar.html | 84 - griffin-ui/tests/ut/karma.conf.js | 102 - .../controllers/createrule-ac-ctrl.spec.js | 129 - .../controllers/createrule-pu-ctrl.spec.js | 105 - .../controllers/createrule-va-ctrl.spec.js | 110 - .../specs/controllers/createrule0-ctrl.spec.js | 62 - .../ut/specs/controllers/health-ctrl.spec.js | 73 - .../ut/specs/controllers/metrics-ctrl.spec.js | 76 - .../tests/ut/specs/controllers/nav-ctrl_spec.js | 47 - .../ut/specs/controllers/rule-ctrl.spec.js | 57 - .../ut/specs/controllers/sidebar-ctrl_spec.js | 89 - .../ut/specs/controllers/viewrule-ctrl.spec.js | 72 - .../tests/ut/specs/filters/strmap_spec.js | 33 - .../tests/ut/specs/filters/strshorten_spec.js | 38 - .../tests/ut/specs/services/services_spec.js | 37 - griffin-ui/tests/ut/test-main.js | 97 - measure/measure-batch/pom.xml | 19 + .../src/main/resources/config-old.json | 45 + .../src/main/resources/config.json | 29 + .../measure-batch/src/main/resources/env.json | 29 + .../src/main/resources/log4j.properties | 5 + .../griffin/measure/batch/Application.scala | 87 + .../measure/batch/algo/AccuracyAlgo.scala | 6 + .../griffin/measure/batch/algo/Algo.scala | 16 + .../measure/batch/algo/BatchAccuracyAlgo.scala | 166 + .../measure/batch/algo/core/AccuracyCore.scala | 78 + .../measure/batch/config/params/AllParam.scala | 14 + .../measure/batch/config/params/Param.scala | 7 + .../batch/config/params/env/CleanerParam.scala | 10 + .../batch/config/params/env/EnvParam.scala | 13 + .../batch/config/params/env/PersistParam.scala | 12 + .../batch/config/params/env/SparkParam.scala | 13 + .../config/params/user/DataConnectorParam.scala | 13 + .../config/params/user/EvaluateRuleParam.scala | 12 + .../batch/config/params/user/UserParam.scala | 15 + .../batch/config/reader/ParamFileReader.scala | 20 + .../config/reader/ParamHdfsFileReader.scala | 20 + .../config/reader/ParamRawStringReader.scala | 17 + .../batch/config/reader/ParamReader.scala | 12 + .../config/reader/ParamReaderFactory.scala | 22 + .../config/validator/AllParamValidator.scala | 16 + .../batch/config/validator/ParamValidator.scala | 12 + .../batch/connector/AvroDataConnector.scala | 91 + .../measure/batch/connector/CacheDataUtil.scala | 63 + .../measure/batch/connector/DataConnector.scala | 16 + .../batch/connector/DataConnectorFactory.scala | 35 + .../batch/connector/HiveDataConnector.scala | 113 + .../griffin/measure/batch/log/Loggable.scala | 25 + .../measure/batch/persist/HdfsPersist.scala | 119 + .../measure/batch/persist/HttpPersist.scala | 44 + .../measure/batch/persist/MultiPersists.scala | 27 + .../griffin/measure/batch/persist/Persist.scala | 23 + .../measure/batch/persist/PersistFactory.scala | 30 + .../measure/batch/result/AccuracyResult.scala | 26 + .../griffin/measure/batch/result/Result.scala | 14 + .../measure/batch/result/ResultInfo.scala | 39 + .../measure/batch/rule/RuleAnalyzer.scala | 28 + .../measure/batch/rule/RuleFactory.scala | 34 + .../griffin/measure/batch/rule/RuleParser.scala | 298 + .../batch/rule/expr/AnalyzableExpr.scala | 7 + .../measure/batch/rule/expr/Cacheable.scala | 15 + .../measure/batch/rule/expr/Calculatable.scala | 7 + .../batch/rule/expr/DataSourceable.scala | 10 + .../measure/batch/rule/expr/Describable.scala | 15 + .../griffin/measure/batch/rule/expr/Expr.scala | 33 + .../measure/batch/rule/expr/ExprDescOnly.scala | 22 + .../measure/batch/rule/expr/ExprIdCounter.scala | 42 + .../measure/batch/rule/expr/FieldDescOnly.scala | 40 + .../measure/batch/rule/expr/LiteralExpr.scala | 68 + .../measure/batch/rule/expr/LogicalExpr.scala | 159 + .../measure/batch/rule/expr/MathExpr.scala | 79 + .../measure/batch/rule/expr/SelectExpr.scala | 53 + .../measure/batch/rule/expr/StatementExpr.scala | 52 + .../measure/batch/utils/CalculationUtil.scala | 265 + .../griffin/measure/batch/utils/HdfsUtil.scala | 62 + .../griffin/measure/batch/utils/HttpUtil.scala | 30 + .../griffin/measure/batch/utils/JsonUtil.scala | 32 + .../measure/batch/utils/StringParseUtil.scala | 10 + .../src/test/resources/config.json | 25 + .../src/test/resources/config1.json | 27 + .../measure-batch/src/test/resources/env.json | 27 + .../measure-batch/src/test/resources/env1.json | 21 + .../src/test/resources/log4j.properties | 5 + .../src/test/resources/users_info_src.avro | Bin 0 -> 3850 bytes .../src/test/resources/users_info_src.dat | 50 + .../src/test/resources/users_info_target.avro | Bin 0 -> 3852 bytes .../src/test/resources/users_info_target.dat | 50 + .../batch/algo/BatchAccuracyAlgoTest.scala | 223 + .../config/reader/ParamFileReaderTest.scala | 34 + .../measure/batch/rule/RuleParserTest.scala | 74 + measure/pom.xml | 193 + pom.xml | 903 +- service/pom.xml | 155 + .../griffin/core/GriffinWebApplication.java | 68 + .../griffin/core/common/SimpleCORSFilter.java | 46 + .../griffin/core/measure/AuditableEntity.java | 67 + .../griffin/core/measure/DataConnector.java | 66 + .../griffin/core/measure/EvaluateRule.java | 20 + .../apache/griffin/core/measure/Measure.java | 117 + .../griffin/core/measure/MeasureController.java | 89 + .../core/measure/repo/ConnectorConfigRepo.java | 0 .../core/measure/repo/DataConnectorRepo.java | 10 + .../core/measure/repo/EvaluateRuleRepo.java | 10 + .../griffin/core/measure/repo/MeasureRepo.java | 9 + .../core/metastore/HiveMetastoreController.java | 56 + .../core/metastore/HiveMetastoreProxy.java | 42 + .../core/metastore/HiveMetastoreService.java | 105 + .../core/metastore/KafkaSchemaController.java | 48 + .../core/metastore/KafkaSchemaService.java | 118 + .../AutowiringSpringBeanJobFactory.java | 26 + .../org/apache/griffin/core/schedule/Conf.java | 16 + .../griffin/core/schedule/SchedulerConfig.java | 44 + .../core/schedule/SchedulerController.java | 156 + .../core/schedule/SchedulerRequestBody.java | 53 + .../griffin/core/schedule/SparkJobDO.java | 131 + .../griffin/core/schedule/SparkSubmitJob.java | 221 + .../griffin/core/service/GriffinController.java | 17 + .../org/apache/griffin/core/util/AvroUtil.java | 11 + service/src/main/resources/Init_quartz.sql | 179 + .../main/resources/application-prod.properties | 19 + .../src/main/resources/application.properties | 22 + .../src/main/resources/public/apidocs/bark.json | 737 + .../main/resources/public/apidocs/css/print.css | 1187 + .../main/resources/public/apidocs/css/reset.css | 125 + .../resources/public/apidocs/css/screen.css | 1300 + .../main/resources/public/apidocs/css/style.css | 250 + .../resources/public/apidocs/css/typography.css | 14 + .../public/apidocs/example/anomaly.json | 19 + .../public/apidocs/example/publish.json | 17 + .../public/apidocs/example/validity.json | 20 + .../public/apidocs/fonts/DroidSans-Bold.ttf | Bin 0 -> 57943 bytes .../public/apidocs/fonts/DroidSans.ttf | Bin 0 -> 56397 bytes .../public/apidocs/images/collapse.gif | Bin 0 -> 69 bytes .../resources/public/apidocs/images/expand.gif | Bin 0 -> 73 bytes .../public/apidocs/images/explorer_icons.png | Bin 0 -> 5763 bytes .../public/apidocs/images/favicon-16x16.png | Bin 0 -> 645 bytes .../public/apidocs/images/favicon-32x32.png | Bin 0 -> 1654 bytes .../resources/public/apidocs/images/favicon.ico | Bin 0 -> 12710 bytes .../public/apidocs/images/logo_small.png | Bin 0 -> 770 bytes .../public/apidocs/images/pet_store_api.png | Bin 0 -> 824 bytes .../public/apidocs/images/throbber.gif | Bin 0 -> 9257 bytes .../public/apidocs/images/wordnik_api.png | Bin 0 -> 980 bytes .../main/resources/public/apidocs/index.html | 125 + .../main/resources/public/apidocs/lang/en.js | 55 + .../main/resources/public/apidocs/lang/es.js | 52 + .../main/resources/public/apidocs/lang/fr.js | 53 + .../main/resources/public/apidocs/lang/it.js | 52 + .../main/resources/public/apidocs/lang/ja.js | 53 + .../main/resources/public/apidocs/lang/pl.js | 53 + .../main/resources/public/apidocs/lang/pt.js | 53 + .../main/resources/public/apidocs/lang/ru.js | 55 + .../main/resources/public/apidocs/lang/tr.js | 53 + .../resources/public/apidocs/lang/translator.js | 39 + .../main/resources/public/apidocs/lang/zh-cn.js | 53 + .../public/apidocs/lib/backbone-min.js | 15 + .../public/apidocs/lib/handlebars-2.0.0.js | 28 + .../public/apidocs/lib/highlight.7.3.pack.js | 1 + .../public/apidocs/lib/jquery-1.8.0.min.js | 2 + .../public/apidocs/lib/jquery.ba-bbq.min.js | 18 + .../public/apidocs/lib/jquery.slideto.min.js | 1 + .../public/apidocs/lib/jquery.wiggle.min.js | 8 + .../public/apidocs/lib/jsoneditor.min.js | 11 + .../main/resources/public/apidocs/lib/marked.js | 1272 + .../public/apidocs/lib/swagger-oauth.js | 338 + .../public/apidocs/lib/underscore-min.js | 6 + .../public/apidocs/lib/underscore-min.map | 1 + .../src/main/resources/public/apidocs/o2c.html | 20 + .../resources/public/apidocs/pet_example.json | 426 + .../main/resources/public/apidocs/sample.json | 83 + .../main/resources/public/apidocs/swagger-ui.js | 26330 +++++++ .../resources/public/apidocs/swagger-ui.min.js | 11 + .../main/resources/public/apidocs/swagger.json | 1633 + service/src/main/resources/public/bower.json | 19 + .../AngularJS-Toaster/toaster.css | 240 + .../AngularJS-Toaster/toaster.js | 504 + .../AngularJS-Toaster/toaster.min.css | 12 + .../AngularJS-Toaster/toaster.min.js | 13 + .../angular-animate/angular-animate.js | 4139 ++ .../angular-animate/angular-animate.min.js | 57 + .../angular-cookies/angular-cookies.js | 322 + .../angular-cookies/angular-cookies.min.js | 9 + .../angular-route/angular-route.js | 1069 + .../angular-route/angular-route.min.js | 16 + .../angular-smart-table/dist/smart-table.js | 539 + .../angular-smart-table/dist/smart-table.min.js | 6 + .../angular-spinner/angular-spinner.js | 137 + .../angular-spinner/angular-spinner.min.js | 2 + .../bower_components/angular/angular-csp.css | 21 + .../public/bower_components/angular/angular.js | 31768 +++++++++ .../bower_components/angular/angular.min.js | 318 + .../bootstrap/dist/js/bootstrap.js | 2377 + .../bootstrap/dist/js/bootstrap.min.js | 7 + .../bootswatch/cyborg/bootstrap.css | 6929 ++ .../bootswatch/cyborg/bootstrap.min.css | 11 + .../fonts/glyphicons-halflings-regular.eot | Bin 0 -> 35366 bytes .../fonts/glyphicons-halflings-regular.svg | 288 + .../fonts/glyphicons-halflings-regular.ttf | Bin 0 -> 58132 bytes .../fonts/glyphicons-halflings-regular.woff | Bin 0 -> 42777 bytes .../fonts/glyphicons-halflings-regular.woff2 | Bin 0 -> 32485 bytes .../bower_components/domReady/domReady.js | 129 + .../bower_components/echarts/dist/echarts.js | 63245 +++++++++++++++++ .../echarts/dist/echarts.min.js | 35 + .../bower_components/echarts/theme/dark.js | 152 + .../font-awesome/css/font-awesome.css | 2086 + .../font-awesome/css/font-awesome.min.css | 4 + .../font-awesome/fonts/FontAwesome.otf | Bin 0 -> 209181 bytes .../font-awesome/fonts/fontawesome-webfont.eot | Bin 0 -> 126223 bytes .../font-awesome/fonts/fontawesome-webfont.svg | 655 + .../font-awesome/fonts/fontawesome-webfont.ttf | Bin 0 -> 182555 bytes .../font-awesome/fonts/fontawesome-webfont.woff | Bin 0 -> 151593 bytes .../fonts/fontawesome-webfont.woff.bak | Bin 0 -> 151593 bytes .../fonts/fontawesome-webfont.woff2 | Bin 0 -> 120891 bytes .../bower_components/jquery/dist/jquery.js | 9210 +++ .../bower_components/jquery/dist/jquery.min.js | 5 + .../bower_components/requirejs/require.js | 2129 + .../public/bower_components/spin.js/spin.js | 377 + .../public/bower_components/spin.js/spin.min.js | 2 + service/src/main/resources/public/build.xml | 28 + service/src/main/resources/public/css/main.css | 1053 + .../src/main/resources/public/css/sidebar.css | 179 + .../resources/public/css/treeview-check.css | 81 + .../src/main/resources/public/css/treeview.css | 81 + service/src/main/resources/public/img/1.PNG | Bin 0 -> 13855 bytes service/src/main/resources/public/img/2.PNG | Bin 0 -> 8562 bytes .../src/main/resources/public/img/bollinger.png | Bin 0 -> 145323 bytes .../main/resources/public/img/construction.gif | Bin 0 -> 4853 bytes .../src/main/resources/public/img/favicon.ico | Bin 0 -> 17912 bytes service/src/main/resources/public/img/logo.gif | Bin 0 -> 5764 bytes service/src/main/resources/public/img/mad.png | Bin 0 -> 47922 bytes .../src/main/resources/public/img/sidebar1.png | Bin 0 -> 1536 bytes .../src/main/resources/public/img/sidebar2.png | Bin 0 -> 1617 bytes service/src/main/resources/public/img/yoy.png | Bin 0 -> 28400 bytes service/src/main/resources/public/index.html | 185 + service/src/main/resources/public/js/app.js | 42 + service/src/main/resources/public/js/bs.js | 31 + .../public/js/controllers/bigChart-ctrl.js | 58 + .../js/controllers/createdataasset-ctrl.js | 180 + .../public/js/controllers/createrule-ac-ctrl.js | 562 + .../public/js/controllers/createrule-an-ctrl.js | 298 + .../public/js/controllers/createrule-pu-ctrl.js | 161 + .../public/js/controllers/createrule-va-ctrl.js | 331 + .../public/js/controllers/createrule0-ctrl.js | 41 + .../public/js/controllers/dataassets-ctrl.js | 124 + .../js/controllers/downloadSample-ctrl.js | 36 + .../public/js/controllers/editdataasset-ctrl.js | 213 + .../public/js/controllers/footer-ctrl.js | 56 + .../public/js/controllers/health-ctrl.js | 191 + .../resources/public/js/controllers/index.js | 40 + .../public/js/controllers/main-ctrl.js | 36 + .../public/js/controllers/metrics-ctrl.js | 180 + .../resources/public/js/controllers/module.js | 18 + .../public/js/controllers/mydashboard-ctrl.js | 84 + .../resources/public/js/controllers/nav-ctrl.js | 65 + .../public/js/controllers/rule-ctrl.js | 172 + .../public/js/controllers/sidebar-ctrl.js | 139 + .../js/controllers/subscribemodel-ctrl.js | 406 + .../public/js/controllers/viewrule-ctrl.js | 92 + .../resources/public/js/directives/bigchart.js | 92 + .../resources/public/js/directives/index.js | 15 + .../resources/public/js/directives/module.js | 18 + .../resources/public/js/directives/treeview.js | 250 + .../main/resources/public/js/filters/index.js | 15 + .../main/resources/public/js/filters/module.js | 20 + .../main/resources/public/js/filters/strmap.js | 66 + .../resources/public/js/filters/strshorten.js | 45 + service/src/main/resources/public/js/main.js | 88 + service/src/main/resources/public/js/routes.js | 221 + .../resources/public/js/services/bark-chart.js | 613 + .../main/resources/public/js/services/index.js | 15 + .../main/resources/public/js/services/module.js | 18 + .../resources/public/js/services/services.js | 107 + .../src/main/resources/public/login/b3vHigh.jpg | Bin 0 -> 555201 bytes .../main/resources/public/login/background.jpg | Bin 0 -> 225253 bytes .../src/main/resources/public/login/login.css | 87 + .../src/main/resources/public/login/login.html | 116 + .../src/main/resources/public/login/login.js | 113 + .../src/main/resources/public/login/logo.gif | Bin 0 -> 59985 bytes service/src/main/resources/public/login/pad.png | Bin 0 -> 140342 bytes service/src/main/resources/public/package.json | 27 + .../dataassets/confirmation-dataasset.html | 120 + .../confirmation-delete-dataasset.html | 100 + .../pages/dataassets/createdataasset.html | 237 + .../public/pages/dataassets/dataassets.html | 99 + .../public/pages/dataassets/editdataasset.html | 219 + .../resources/public/pages/health/health.html | 39 + .../public/pages/metrics/dashboard.html | 59 + .../public/pages/metrics/download-sample.html | 48 + .../resources/public/pages/metrics/metrics.css | 22 + .../mydashboard/confirmation-subscribe.html | 38 + .../public/pages/mydashboard/mydashboard.html | 44 + .../pages/mydashboard/subscribemodel.html | 114 + .../public/pages/rules/confirmation-ac.html | 118 + .../public/pages/rules/confirmation-an.html | 143 + .../public/pages/rules/confirmation-pu.html | 157 + .../public/pages/rules/confirmation-va.html | 157 + .../public/pages/rules/createrule-ac.html | 434 + .../public/pages/rules/createrule-an.html | 406 + .../public/pages/rules/createrule-pu.html | 232 + .../public/pages/rules/createrule-va.html | 403 + .../public/pages/rules/createrule0.html | 251 + .../public/pages/rules/delete-confirm.html | 91 + .../main/resources/public/pages/rules/rule.css | 341 + .../resources/public/pages/rules/rules.html | 101 + .../public/pages/rules/va-explaination.html | 767 + .../resources/public/pages/rules/viewrule.html | 210 + .../public/pages/template/bigchart.css | 89 + .../public/pages/template/bigchart.html | 31 + .../public/pages/template/undercons.html | 18 + service/src/main/resources/public/sidebar.html | 84 + .../resources/public/tests/ut/karma.conf.js | 102 + .../controllers/createrule-ac-ctrl.spec.js | 129 + .../controllers/createrule-pu-ctrl.spec.js | 105 + .../controllers/createrule-va-ctrl.spec.js | 110 + .../specs/controllers/createrule0-ctrl.spec.js | 62 + .../ut/specs/controllers/health-ctrl.spec.js | 73 + .../ut/specs/controllers/metrics-ctrl.spec.js | 76 + .../tests/ut/specs/controllers/nav-ctrl_spec.js | 47 + .../ut/specs/controllers/rule-ctrl.spec.js | 57 + .../ut/specs/controllers/sidebar-ctrl_spec.js | 89 + .../ut/specs/controllers/viewrule-ctrl.spec.js | 72 + .../tests/ut/specs/filters/strmap_spec.js | 33 + .../tests/ut/specs/filters/strshorten_spec.js | 38 + .../tests/ut/specs/services/services_spec.js | 37 + .../main/resources/public/tests/ut/test-main.js | 97 + service/src/main/resources/quartz.properties | 11 + service/src/main/resources/sparkJob.properties | 17 + ui/apidocs/bark.json | 737 + ui/apidocs/css/print.css | 1187 + ui/apidocs/css/reset.css | 125 + ui/apidocs/css/screen.css | 1300 + ui/apidocs/css/style.css | 250 + ui/apidocs/css/typography.css | 14 + ui/apidocs/example/anomaly.json | 19 + ui/apidocs/example/publish.json | 17 + ui/apidocs/example/validity.json | 20 + ui/apidocs/fonts/DroidSans-Bold.ttf | Bin 0 -> 42480 bytes ui/apidocs/fonts/DroidSans.ttf | Bin 0 -> 41028 bytes ui/apidocs/images/collapse.gif | Bin 0 -> 69 bytes ui/apidocs/images/expand.gif | Bin 0 -> 73 bytes ui/apidocs/images/explorer_icons.png | Bin 0 -> 5763 bytes ui/apidocs/images/favicon-16x16.png | Bin 0 -> 645 bytes ui/apidocs/images/favicon-32x32.png | Bin 0 -> 1654 bytes ui/apidocs/images/favicon.ico | Bin 0 -> 5430 bytes ui/apidocs/images/logo_small.png | Bin 0 -> 770 bytes ui/apidocs/images/pet_store_api.png | Bin 0 -> 824 bytes ui/apidocs/images/throbber.gif | Bin 0 -> 9257 bytes ui/apidocs/images/wordnik_api.png | Bin 0 -> 980 bytes ui/apidocs/index.html | 125 + ui/apidocs/lang/en.js | 55 + ui/apidocs/lang/es.js | 52 + ui/apidocs/lang/fr.js | 53 + ui/apidocs/lang/it.js | 52 + ui/apidocs/lang/ja.js | 53 + ui/apidocs/lang/pl.js | 53 + ui/apidocs/lang/pt.js | 53 + ui/apidocs/lang/ru.js | 55 + ui/apidocs/lang/tr.js | 53 + ui/apidocs/lang/translator.js | 39 + ui/apidocs/lang/zh-cn.js | 53 + ui/apidocs/lib/backbone-min.js | 15 + ui/apidocs/lib/handlebars-2.0.0.js | 28 + ui/apidocs/lib/highlight.7.3.pack.js | 1 + ui/apidocs/lib/jquery-1.8.0.min.js | 2 + ui/apidocs/lib/jquery.ba-bbq.min.js | 18 + ui/apidocs/lib/jquery.slideto.min.js | 1 + ui/apidocs/lib/jquery.wiggle.min.js | 8 + ui/apidocs/lib/jsoneditor.min.js | 11 + ui/apidocs/lib/marked.js | 1272 + ui/apidocs/lib/swagger-oauth.js | 338 + ui/apidocs/lib/underscore-min.js | 6 + ui/apidocs/lib/underscore-min.map | 1 + ui/apidocs/o2c.html | 20 + ui/apidocs/pet_example.json | 426 + ui/apidocs/sample.json | 83 + ui/apidocs/swagger-ui.js | 26330 +++++++ ui/apidocs/swagger-ui.min.js | 11 + ui/apidocs/swagger.json | 1633 + ui/bower.json | 19 + .../AngularJS-Toaster/toaster.css | 240 + .../AngularJS-Toaster/toaster.js | 504 + .../AngularJS-Toaster/toaster.min.css | 12 + .../AngularJS-Toaster/toaster.min.js | 13 + .../angular-animate/angular-animate.js | 4139 ++ .../angular-animate/angular-animate.min.js | 57 + .../angular-cookies/angular-cookies.js | 322 + .../angular-cookies/angular-cookies.min.js | 9 + .../angular-route/angular-route.js | 1069 + .../angular-route/angular-route.min.js | 16 + .../angular-smart-table/dist/smart-table.js | 539 + .../angular-smart-table/dist/smart-table.min.js | 6 + .../angular-spinner/angular-spinner.js | 137 + .../angular-spinner/angular-spinner.min.js | 2 + ui/bower_components/angular/angular-csp.css | 21 + ui/bower_components/angular/angular.js | 31768 +++++++++ ui/bower_components/angular/angular.min.js | 318 + .../bootstrap/dist/js/bootstrap.js | 2377 + .../bootstrap/dist/js/bootstrap.min.js | 7 + .../bootswatch/cyborg/bootstrap.css | 6929 ++ .../bootswatch/cyborg/bootstrap.min.css | 11 + .../fonts/glyphicons-halflings-regular.eot | Bin 0 -> 20127 bytes .../fonts/glyphicons-halflings-regular.svg | 288 + .../fonts/glyphicons-halflings-regular.ttf | Bin 0 -> 45404 bytes .../fonts/glyphicons-halflings-regular.woff | Bin 0 -> 23424 bytes .../fonts/glyphicons-halflings-regular.woff2 | Bin 0 -> 18028 bytes ui/bower_components/domReady/domReady.js | 129 + ui/bower_components/echarts/dist/echarts.js | 63245 +++++++++++++++++ ui/bower_components/echarts/dist/echarts.min.js | 35 + ui/bower_components/echarts/theme/dark.js | 152 + .../font-awesome/css/font-awesome.css | 2086 + .../font-awesome/css/font-awesome.min.css | 4 + .../font-awesome/fonts/FontAwesome.otf | Bin 0 -> 109688 bytes .../font-awesome/fonts/fontawesome-webfont.eot | Bin 0 -> 70807 bytes .../font-awesome/fonts/fontawesome-webfont.svg | 655 + .../font-awesome/fonts/fontawesome-webfont.ttf | Bin 0 -> 142072 bytes .../font-awesome/fonts/fontawesome-webfont.woff | Bin 0 -> 83588 bytes .../fonts/fontawesome-webfont.woff.bak | Bin 0 -> 83588 bytes .../fonts/fontawesome-webfont.woff2 | Bin 0 -> 66624 bytes ui/bower_components/jquery/dist/jquery.js | 9210 +++ ui/bower_components/jquery/dist/jquery.min.js | 5 + ui/bower_components/requirejs/require.js | 2129 + ui/bower_components/spin.js/spin.js | 377 + ui/bower_components/spin.js/spin.min.js | 2 + ui/build.xml | 28 + ui/css/main.css | 1053 + ui/css/sidebar.css | 179 + ui/css/treeview-check.css | 81 + ui/css/treeview.css | 81 + ui/img/1.PNG | Bin 0 -> 13855 bytes ui/img/2.PNG | Bin 0 -> 8562 bytes ui/img/bollinger.png | Bin 0 -> 145323 bytes ui/img/construction.gif | Bin 0 -> 4853 bytes ui/img/favicon.ico | Bin 0 -> 9920 bytes ui/img/logo.gif | Bin 0 -> 5764 bytes ui/img/mad.png | Bin 0 -> 47922 bytes ui/img/sidebar1.png | Bin 0 -> 1536 bytes ui/img/sidebar2.png | Bin 0 -> 1617 bytes ui/img/yoy.png | Bin 0 -> 28400 bytes ui/index.html | 185 + ui/js/app.js | 42 + ui/js/bs.js | 31 + ui/js/controllers/bigChart-ctrl.js | 58 + ui/js/controllers/createdataasset-ctrl.js | 180 + ui/js/controllers/createrule-ac-ctrl.js | 562 + ui/js/controllers/createrule-an-ctrl.js | 298 + ui/js/controllers/createrule-pu-ctrl.js | 161 + ui/js/controllers/createrule-va-ctrl.js | 331 + ui/js/controllers/createrule0-ctrl.js | 41 + ui/js/controllers/dataassets-ctrl.js | 124 + ui/js/controllers/downloadSample-ctrl.js | 36 + ui/js/controllers/editdataasset-ctrl.js | 213 + ui/js/controllers/footer-ctrl.js | 56 + ui/js/controllers/health-ctrl.js | 191 + ui/js/controllers/index.js | 40 + ui/js/controllers/main-ctrl.js | 36 + ui/js/controllers/metrics-ctrl.js | 180 + ui/js/controllers/module.js | 18 + ui/js/controllers/mydashboard-ctrl.js | 84 + ui/js/controllers/nav-ctrl.js | 65 + ui/js/controllers/rule-ctrl.js | 172 + ui/js/controllers/sidebar-ctrl.js | 139 + ui/js/controllers/subscribemodel-ctrl.js | 406 + ui/js/controllers/viewrule-ctrl.js | 92 + ui/js/directives/bigchart.js | 92 + ui/js/directives/index.js | 15 + ui/js/directives/module.js | 18 + ui/js/directives/treeview.js | 250 + ui/js/filters/index.js | 15 + ui/js/filters/module.js | 20 + ui/js/filters/strmap.js | 66 + ui/js/filters/strshorten.js | 45 + ui/js/main.js | 88 + ui/js/routes.js | 221 + ui/js/services/bark-chart.js | 613 + ui/js/services/index.js | 15 + ui/js/services/module.js | 18 + ui/js/services/services.js | 107 + ui/login/b3vHigh.jpg | Bin 0 -> 555201 bytes ui/login/background.jpg | Bin 0 -> 225253 bytes ui/login/login.css | 87 + ui/login/login.html | 116 + ui/login/login.js | 113 + ui/login/logo.gif | Bin 0 -> 59985 bytes ui/login/pad.png | Bin 0 -> 140342 bytes ui/package.json | 27 + ui/pages/dataassets/confirmation-dataasset.html | 120 + .../confirmation-delete-dataasset.html | 100 + ui/pages/dataassets/createdataasset.html | 237 + ui/pages/dataassets/dataassets.html | 99 + ui/pages/dataassets/editdataasset.html | 219 + ui/pages/health/health.html | 39 + ui/pages/metrics/dashboard.html | 59 + ui/pages/metrics/download-sample.html | 48 + ui/pages/metrics/metrics.css | 22 + .../mydashboard/confirmation-subscribe.html | 38 + ui/pages/mydashboard/mydashboard.html | 44 + ui/pages/mydashboard/subscribemodel.html | 114 + ui/pages/rules/confirmation-ac.html | 118 + ui/pages/rules/confirmation-an.html | 143 + ui/pages/rules/confirmation-pu.html | 157 + ui/pages/rules/confirmation-va.html | 157 + ui/pages/rules/createrule-ac.html | 434 + ui/pages/rules/createrule-an.html | 406 + ui/pages/rules/createrule-pu.html | 232 + ui/pages/rules/createrule-va.html | 403 + ui/pages/rules/createrule0.html | 251 + ui/pages/rules/delete-confirm.html | 91 + ui/pages/rules/rule.css | 341 + ui/pages/rules/rules.html | 101 + ui/pages/rules/va-explaination.html | 767 + ui/pages/rules/viewrule.html | 210 + ui/pages/template/bigchart.css | 89 + ui/pages/template/bigchart.html | 31 + ui/pages/template/undercons.html | 18 + ui/pom.xml | 73 + ui/sidebar.html | 84 + ui/src/main/java/jar/App.java | 13 + ui/src/test/java/jar/AppTest.java | 38 + ui/tests/ut/karma.conf.js | 102 + .../controllers/createrule-ac-ctrl.spec.js | 129 + .../controllers/createrule-pu-ctrl.spec.js | 105 + .../controllers/createrule-va-ctrl.spec.js | 110 + .../specs/controllers/createrule0-ctrl.spec.js | 62 + .../ut/specs/controllers/health-ctrl.spec.js | 73 + .../ut/specs/controllers/metrics-ctrl.spec.js | 76 + ui/tests/ut/specs/controllers/nav-ctrl_spec.js | 47 + ui/tests/ut/specs/controllers/rule-ctrl.spec.js | 57 + .../ut/specs/controllers/sidebar-ctrl_spec.js | 89 + .../ut/specs/controllers/viewrule-ctrl.spec.js | 72 + ui/tests/ut/specs/filters/strmap_spec.js | 33 + ui/tests/ut/specs/filters/strshorten_spec.js | 38 + ui/tests/ut/specs/services/services_spec.js | 37 + ui/tests/ut/test-main.js | 97 + 902 files changed, 355163 insertions(+), 189989 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/.gitignore ---------------------------------------------------------------------- diff --git a/.gitignore b/.gitignore index b6404c2..9090598 100644 --- a/.gitignore +++ b/.gitignore @@ -12,6 +12,12 @@ target/** *.war *.ear target +service/src/main/resource/public/** + +.project +.settings/ +.classpath +bin # virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml hs_err_pid* http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/.gitignore ---------------------------------------------------------------------- diff --git a/griffin-core/.gitignore b/griffin-core/.gitignore deleted file mode 100644 index c13c943..0000000 --- a/griffin-core/.gitignore +++ /dev/null @@ -1,27 +0,0 @@ -dist -build -bin -rebel.xml -MANIFEST.MF -/tests/ -/coverage/ -/cobertura.ser -*/ebay.log -*.class -*.jar -*.zip -*/target/* -*/temp_persist_config_*.xml -*/src/main/resources/buildinfo.properties -/.idea/ -**/*.iml -build.xml -ebay-build.xml -4cc.checksum -/.metadata -/.project -/target/** -/.settings/** -/target/ -/.externalToolBuilders/ -/.classpath http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/pom.xml ---------------------------------------------------------------------- diff --git a/griffin-core/pom.xml b/griffin-core/pom.xml deleted file mode 100644 index 752a8fd..0000000 --- a/griffin-core/pom.xml +++ /dev/null @@ -1,302 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- Copyright (c) 2016 eBay Software Foundation. Licensed under the Apache - License, Version 2.0 (the "License"); you may not use this file except in - compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 - Unless required by applicable law or agreed to in writing, software distributed - under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES - OR CONDITIONS OF ANY KIND, either express or implied. See the License for - the specific language governing permissions and limitations under the License. --> -<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> - - <parent> - <groupId>com.ebay.oss</groupId> - <artifactId>griffin-parent</artifactId> - <version>0.1.0-SNAPSHOT</version> - <relativePath>../pom.xml</relativePath> - </parent> - - - <modelVersion>4.0.0</modelVersion> - <artifactId>griffin-core</artifactId> - <name>griffin-core</name> - <packaging>war</packaging> - - - <dependencies> - - <!-- <dependency> <groupId>commons-io</groupId> <artifactId>commons-io</artifactId> - <version>2.4</version> </dependency> --> - - <dependency> - <groupId>javax.servlet</groupId> - <artifactId>javax.servlet-api</artifactId> - <version>3.0.1</version> - <scope>provided</scope> - </dependency> - - - - <dependency> - <groupId>com.google.code.gson</groupId> - <artifactId>gson</artifactId> - </dependency> - <dependency> - <groupId>org.hibernate</groupId> - <artifactId>hibernate-validator</artifactId> - <version>5.2.4.Final</version> - </dependency> - - <dependency> - <groupId>org.slf4j</groupId> - <artifactId>slf4j-api</artifactId> - </dependency> - - <!-- Jersey --> - <dependency> - <groupId>com.sun.jersey</groupId> - <artifactId>jersey-server</artifactId> - </dependency> - <dependency> - <groupId>com.sun.jersey</groupId> - <artifactId>jersey-json</artifactId> - - </dependency> - <dependency> - <groupId>com.sun.jersey</groupId> - <artifactId>jersey-bundle</artifactId> - </dependency> - - <dependency> - <groupId>org.aspectj</groupId> - <artifactId>aspectjweaver</artifactId> - <version>1.6.10</version> - </dependency> - - <!-- Spring 3 dependencies --> - <dependency> - <groupId>org.springframework</groupId> - <artifactId>spring-core</artifactId> - <version>3.2.8.RELEASE</version> - </dependency> - - <dependency> - <groupId>org.springframework</groupId> - <artifactId>spring-context</artifactId> - <version>3.2.8.RELEASE</version> - </dependency> - - <dependency> - <groupId>org.springframework</groupId> - <artifactId>spring-webmvc</artifactId> - <version>3.2.8.RELEASE</version> - </dependency> - - <dependency> - <groupId>org.apache.hadoop</groupId> - <artifactId>hadoop-common</artifactId> - - </dependency> - - - - <!-- <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-hdfs</artifactId> --> - <!-- </dependency> <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-client</artifactId> - </dependency> <dependency> <groupId>org.apache.hadoop</groupId> <artifactId>hadoop-auth</artifactId> --> - - <!-- </dependency> --> - - <!-- Jersey + Spring --> - <dependency> - <groupId>com.sun.jersey.contribs</groupId> - <artifactId>jersey-spring</artifactId> - <version>${jersey.version}</version> - <exclusions> - <exclusion> - <groupId>org.springframework</groupId> - <artifactId>spring</artifactId> - </exclusion> - <exclusion> - <groupId>org.springframework</groupId> - <artifactId>spring-core</artifactId> - </exclusion> - <exclusion> - <groupId>org.springframework</groupId> - <artifactId>spring-web</artifactId> - </exclusion> - <exclusion> - <groupId>org.springframework</groupId> - <artifactId>spring-webmvc</artifactId> - </exclusion> - <exclusion> - <groupId>org.springframework</groupId> - <artifactId>spring-beans</artifactId> - </exclusion> - <exclusion> - <groupId>org.springframework</groupId> - <artifactId>spring-context</artifactId> - </exclusion> - <exclusion> - <groupId>org.springframework</groupId> - <artifactId>spring-aop</artifactId> - </exclusion> - - </exclusions> - </dependency> - - <dependency> - <groupId>org.mongodb</groupId> - <artifactId>mongo-java-driver</artifactId> - <version>${mongo.version}</version> - </dependency> - - <!-- <dependency> <groupId>javax.ws.rs</groupId> <artifactId>javax.ws.rs-api</artifactId> - <version>2.0</version> </dependency> --> - - <dependency> - <groupId>com.google.code.morphia</groupId> - <artifactId>morphia</artifactId> - <version>0.104</version> - </dependency> - <!-- <dependency> <groupId>org.codehaus.jackson</groupId> <artifactId>jackson-core-asl</artifactId> - </dependency> <dependency> <groupId>commons-digester</groupId> <artifactId>commons-digester</artifactId> - <version>2.1</version> </dependency> <dependency> <groupId>org.aspectj</groupId> - <artifactId>aspectjrt</artifactId> <version>1.8.1</version> </dependency> --> - - <!-- <dependency> - <groupId>org.apache.griffin</groupId> - <artifactId>griffin-scheduler</artifactId> - <version>${griffin.version}</version> - <scope>compile</scope> - </dependency> --> - <dependency> - <groupId>${project.groupId}</groupId> - <artifactId>griffin-ui</artifactId> - <version>${griffin.version}</version> - <classifier>resources</classifier> - <type>zip</type> - <!-- Make sure this isn't included on any classpath --> - <scope>provided</scope> - </dependency> - <!-- <dependency> <groupId>org.apache.griffin</groupId> <artifactId>griffin-core</artifactId> - <version>0.0.1-SNAPSHOT</version> <scope>compile</scope> </dependency> --> - <dependency> - <groupId>junit</groupId> - <artifactId>junit</artifactId> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.mockito</groupId> - <artifactId>mockito-all</artifactId> - </dependency> - <dependency> - <groupId>org.springframework</groupId> - <artifactId>spring-test</artifactId> - <version>3.2.8.RELEASE</version> - <scope>test</scope> - </dependency> - - <!-- Guice ============================================================= - <dependency> <groupId>com.google.inject</groupId> <artifactId>guice</artifactId> - <version>${guice.version}</version> <scope>test</scope> </dependency> <dependency> - <groupId>com.google.inject.extensions</groupId> <artifactId>guice-servlet</artifactId> - <version>${guice.version}</version> <scope>test</scope> </dependency> <dependency> - <groupId>com.sun.jersey.contribs</groupId> <artifactId>jersey-guice</artifactId> - <version>${jersey.version}</version> <scope>test</scope> </dependency> --> - <dependency> - <groupId>com.sun.jersey</groupId> - <artifactId>jersey-client</artifactId> - <scope>test</scope> - </dependency> - - <dependency> - <groupId>com.sun.jersey</groupId> - <artifactId>jersey-grizzly2</artifactId> - <version>${jersey.version}</version> - <scope>test</scope> - </dependency> - - - </dependencies> - - <build> - <finalName>ROOT</finalName> - <plugins> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-compiler-plugin</artifactId> - <configuration> - <source>1.7</source> - <target>1.7</target> - </configuration> - </plugin> - <!-- <plugin> - <artifactId>maven-war-plugin</artifactId> - <version>2.1.1</version> - <configuration> - <attachClasses>true</attachClasses> - <classesClassifier>classes</classesClassifier> - </configuration> - </plugin> --> - - <plugin> - <groupId>org.codehaus.mojo</groupId> - <artifactId>cobertura-maven-plugin</artifactId> - <version>2.6</version> - <configuration> - <formats> - <format>html</format> - <format>xml</format> - </formats> - </configuration> - </plugin> - - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-war-plugin</artifactId> - <version>2.6</version> - <configuration> - <webResources> - <resource> - <directory>${project.build.directory}/generated-resources/griffin-ui-${griffin.version}</directory> - </resource> - </webResources> - <attachClasses>true</attachClasses> - <classesClassifier>classes</classesClassifier> - </configuration> - </plugin> - - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-dependency-plugin</artifactId> - <executions> - <execution> - <id>unpack-shared-resources</id> - <goals> - <goal>unpack-dependencies</goal> - </goals> - <phase>generate-resources</phase> - <configuration> - <outputDirectory>${project.build.directory}/generated-resources</outputDirectory> - <includeArtifacIds>griffin-ui</includeArtifacIds> - <includeGroupIds>${project.groupId}</includeGroupIds> - <overWriteReleases>true</overWriteReleases> - <overWriteSnapshots>true</overWriteSnapshots> - </configuration> - </execution> - </executions> - </plugin> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-surefire-plugin</artifactId> - <configuration> - <skipTests>true</skipTests> - </configuration> - </plugin> - - </plugins> - - - </build> - -</project> http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/common/HDFSUtils.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/common/HDFSUtils.java b/griffin-core/src/main/java/com/ebay/oss/griffin/common/HDFSUtils.java deleted file mode 100644 index 3b090ec..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/common/HDFSUtils.java +++ /dev/null @@ -1,33 +0,0 @@ -package com.ebay.oss.griffin.common; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - - -public class HDFSUtils { - - static Logger logger = LoggerFactory.getLogger(HDFSUtils.class); - - public static boolean checkHDFSFolder(String folderPath) { - - Process processMoveFolder; - int result; - try { - processMoveFolder = Runtime.getRuntime().exec("hadoop fs -ls " + folderPath); - - result = processMoveFolder.waitFor(); - - if(result == 0) - { - return true; - } - - } catch (Exception e) { - // TODO Auto-generated catch block - e.printStackTrace(); - return false; - } - return false; - } -} - http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/common/NumberUtils.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/common/NumberUtils.java b/griffin-core/src/main/java/com/ebay/oss/griffin/common/NumberUtils.java deleted file mode 100644 index ae051f1..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/common/NumberUtils.java +++ /dev/null @@ -1,41 +0,0 @@ -package com.ebay.oss.griffin.common; - -import org.springframework.util.StringUtils; - -public class NumberUtils { - - public static int parseInt(Object o) { - if (o == null) { - return -1; - } - - String s = o.toString(); - if(StringUtils.isEmpty(s) ) { - return -1; - } - - try { - return Integer.parseInt(s); - } catch (Exception e) { - return -1; - } - } - - public static long parseLong(Object o) { - if (o == null) { - return -1; - } - - String s = o.toString(); - if(StringUtils.isEmpty(s) ) { - return -1; - } - - try { - return Long.parseLong(s); - } catch (Exception e) { - return -1; - } - } - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/common/Pair.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/common/Pair.java b/griffin-core/src/main/java/com/ebay/oss/griffin/common/Pair.java deleted file mode 100644 index f8e3386..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/common/Pair.java +++ /dev/null @@ -1,64 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - */ -package com.ebay.oss.griffin.common; - -public class Pair { - - public final String key; - - public final Object value; - - public Pair(String key, Object value) { - this.key = key; - this.value = value; - } - - @Override - public int hashCode() { - final int prime = 31; - int result = 1; - result = prime * result + ((key == null) ? 0 : key.hashCode()); - result = prime * result + ((value == null) ? 0 : value.hashCode()); - return result; - } - - @Override - public boolean equals(Object obj) { - if (this == obj) - return true; - if (obj == null) - return false; - if (getClass() != obj.getClass()) - return false; - Pair other = (Pair) obj; - if (key == null) { - if (other.key != null) - return false; - } else if (!key.equals(other.key)) - return false; - if (value == null) { - if (other.value != null) - return false; - } else if (!value.equals(other.value)) - return false; - return true; - } - - - @Override - public String toString() { - return "Pair [key=" + key + ", value=" + value + "]"; - } -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/common/ScheduleModelSeperator.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/common/ScheduleModelSeperator.java b/griffin-core/src/main/java/com/ebay/oss/griffin/common/ScheduleModelSeperator.java deleted file mode 100644 index 14899eb..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/common/ScheduleModelSeperator.java +++ /dev/null @@ -1,21 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - */ -package com.ebay.oss.griffin.common; - -public class ScheduleModelSeperator { - public static final String SEPERATOR = "-=-"; - public static final String SPLIT_SEPERATOR = "-=-"; - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/common/SimpleCORSFilter.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/common/SimpleCORSFilter.java b/griffin-core/src/main/java/com/ebay/oss/griffin/common/SimpleCORSFilter.java deleted file mode 100644 index 924c530..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/common/SimpleCORSFilter.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - */ -package com.ebay.oss.griffin.common; -import java.io.IOException; - -import javax.servlet.Filter; -import javax.servlet.FilterChain; -import javax.servlet.FilterConfig; -import javax.servlet.ServletException; -import javax.servlet.ServletRequest; -import javax.servlet.ServletResponse; -import javax.servlet.http.HttpServletResponse; - - -public class SimpleCORSFilter implements Filter { - - @Override - public void doFilter(ServletRequest req, ServletResponse res, FilterChain chain) throws IOException, ServletException { - HttpServletResponse response = (HttpServletResponse) res; - response.setHeader("Access-Control-Allow-Origin", "*"); - response.setHeader("Access-Control-Allow-Methods", "POST, GET, OPTIONS, DELETE,PUT"); - response.setHeader("Access-Control-Max-Age", "3600"); - response.setHeader("Access-Control-Allow-Headers", "X-PINGOTHER, Origin, X-Requested-With, Content-Type, Accept"); - chain.doFilter(req, res); - } - - @Override - public void init(FilterConfig filterConfig) {} - - @Override - public void destroy() {} - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/domain/AnomalyType.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/domain/AnomalyType.java b/griffin-core/src/main/java/com/ebay/oss/griffin/domain/AnomalyType.java deleted file mode 100644 index 4c2bcf9..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/domain/AnomalyType.java +++ /dev/null @@ -1,26 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - */ -package com.ebay.oss.griffin.domain; - -/** the enumerable type of Anomaly Detection */ -public class AnomalyType { - - public static final int ANOMALY_DEFAULT = 0; - public static final int HISTORY_TREND = 1; - public static final int BOLLINGER_BANDS = 2; - public static final int MAD = 3; - - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DataAsset.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DataAsset.java b/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DataAsset.java deleted file mode 100644 index 3b92040..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DataAsset.java +++ /dev/null @@ -1,199 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - */ -package com.ebay.oss.griffin.domain; - -import java.util.ArrayList; -import java.util.Date; -import java.util.List; - -import com.google.code.morphia.annotations.Embedded; -import com.google.code.morphia.annotations.Entity; -import com.google.code.morphia.annotations.Property; -import com.mongodb.DBObject; - -/** - * A DataAsset is an abstraction of a data source, from which a same type of data comes. A DataAsset - * could be a 'table' in RDB or a topic/feed from a stream. - */ -@Entity("data_assets") -// unique constraint: asssetName + assetType + system -public class DataAsset extends IdEntity{ - - // HDP the only one - @Property("platform") - private String platform; - - // SystemTypeConstants - @Property("system") - private String system; - - // e.g. viewitem - @Property("assetName") - private String assetName; - - // HiveTable the only one - @Property("assetType") - private String assetType; - - @Property("assetHDFSPath") - private String assetHDFSPath; - - @Property("owner") - private String owner; - - // createdDate - @Property("timestamp") - private Date timestamp; - - - // home-made schema, DataSchema is atually a simple schemaItem, a schema consists of a list of - // schemaItem - @Embedded - private List<DataSchema> schema = new ArrayList<>(); - - // hive table partition format - @Embedded - private List<PartitionFormat> partitions; - - public DataAsset() { } - - // FIXME should be somewhere else, ORM - @SuppressWarnings({"unchecked", "deprecation"}) - public DataAsset(DBObject o) { - this.set_id(Long.parseLong(o.get("_id").toString())); - this.setAssetHDFSPath((String)o.get("assetHDFSPath")); - this.setAssetName((String)o.get("assetName")); - this.setAssetType((String)o.get("assetType")); - - this.setOwner((String)o.get("owner")); - this.setPlatform((String)o.get("platform")); - this.setSystem((String)o.get("system")); - -// this.setPartitions((List<PartitionFormat>) o.get("partitions")); // this doesn't work - if(o.get("partitions")!=null) { - List<PartitionFormat> partitionlist = new ArrayList<PartitionFormat>(); - List<DBObject> tlist = (List<DBObject>) o.get("partitions"); - for(DBObject temp : tlist) { - partitionlist.add(new PartitionFormat(temp.get("name").toString(), temp.get("format").toString())); - } - this.setPartitions(partitionlist); - } - -// this.setSchema((List<DataSchema>) o.get("schema")); - if(o.get("schema")!=null) { - List<DBObject> tlist = (List<DBObject>) o.get("schema"); - List<DataSchema> list = new ArrayList<DataSchema>(); - for(DBObject temp : tlist) { - list.add(new DataSchema(temp.get("name").toString(), temp.get("type").toString(), temp.get("desc").toString(), temp.get("sample").toString())); - } - this.setSchema(list); - } - - if (!o.containsField("timestamp")) { - this.setTimestamp(new Date()); - } else { - this.setTimestamp(new Date(o.get("timestamp").toString())); - } - } - - { - - - } - - public String getPlatform() { - return platform; - } - - public void setPlatform(String platform) { - this.platform = platform; - } - - public String getSystem() { - return system; - } - - public void setSystem(String system) { - this.system = system; - } - - public String getAssetName() { - return assetName; - } - - public void setAssetName(String assetName) { - this.assetName = assetName; - } - - public String getAssetType() { - return assetType; - } - - public void setAssetType(String assetType) { - this.assetType = assetType; - } - - public String getAssetHDFSPath() { - return assetHDFSPath; - } - - public void setAssetHDFSPath(String assetHDFSPath) { - this.assetHDFSPath = assetHDFSPath; - } - - public String getOwner() { - return owner; - } - - public void setOwner(String owner) { - this.owner = owner; - } - - public Date getTimestamp() { - return timestamp; - } - - public void setTimestamp(Date timestamp) { - this.timestamp = timestamp; - } - - public List<DataSchema> getSchema() { - return schema; - } - - public void setSchema(List<DataSchema> schema) { - this.schema = schema; - } - - public List<PartitionFormat> getPartitions() { - return partitions; - } - - public void setPartitions(List<PartitionFormat> partitions) { - this.partitions = partitions; - } - - public int getColId(String colName) { - if(schema == null || schema.isEmpty()) { - return -1; - } - - for (int i = 0; i < schema.size(); i++) { - if (colName.equals(schema.get(i).getName())) - return i; - } - return -1; - } -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DataSchema.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DataSchema.java b/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DataSchema.java deleted file mode 100644 index 6f92a5d..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DataSchema.java +++ /dev/null @@ -1,80 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - */ -package com.ebay.oss.griffin.domain; - -import com.google.code.morphia.annotations.Embedded; -import com.google.code.morphia.annotations.Property; - -/** - * this is a simple representation of a schema system, which describe the data type of a table. - */ -@Embedded -public class DataSchema{ - - @Property("name") - private String name; - - @Property("type") - private String type; - - @Property("desc") - private String desc; - - @Property("sample") - private String sample; - - public DataSchema() { - } - - public DataSchema(String name, String type, String desc, String sample) { - this.name = name; - this.type = type; - this.desc = desc; - this.sample = sample; - } - - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - - public String getType() { - return type; - } - - public void setType(String type) { - this.type = type; - } - - public String getDesc() { - return desc; - } - - public void setDesc(String desc) { - this.desc = desc; - } - - public String getSample() { - return sample; - } - - public void setSample(String sample) { - this.sample = sample; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/f629d0f4/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DqJob.java ---------------------------------------------------------------------- diff --git a/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DqJob.java b/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DqJob.java deleted file mode 100644 index 9a10e8c..0000000 --- a/griffin-core/src/main/java/com/ebay/oss/griffin/domain/DqJob.java +++ /dev/null @@ -1,121 +0,0 @@ -/* - Copyright (c) 2016 eBay Software Foundation. - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. - */ -package com.ebay.oss.griffin.domain; - -import com.google.code.morphia.annotations.Entity; -import com.google.code.morphia.annotations.Id; -import com.google.code.morphia.annotations.Property; - -/** - * A DqJob is an instance of DqSchedule, the frequency/multiplicity is based on ScheduleType. - */ -@Entity("dq_job") -public class DqJob{ - - /** {modelName} + "_" + "yyyy-mm-dd xx:00:00 000".getTime() */ - @Id - private String _id; - - // Inherits from DqSchedule.modelList - @Property("modelList") - private String modelList; - - /** Inherits from DqSchedule#jobType.*/ - @Property("jobType") - private int jobType; - - /** @see JobStatus */ - @Property("status") - private int status; - - @Property("starttime") - private long starttime; - - @Property("content") - private String content; - - @Property("endtime") - private long endtime; - - @Property("value") - private long value; - - public String getId() { - return _id; - } - - public void setId(String _id) { - this._id = _id; - } - - public String getModelList() { - return modelList; - } - - public void setModelList(String modelList) { - this.modelList = modelList; - } - - public int getStatus() { - return status; - } - - public void setStatus(int status) { - this.status = status; - } - - public long getStarttime() { - return starttime; - } - - public void setStarttime(long starttime) { - this.starttime = starttime; - } - - public String getContent() { - return content; - } - - public void setContent(String content) { - this.content = content; - } - - public long getEndtime() { - return endtime; - } - - public void setEndtime(long endtime) { - this.endtime = endtime; - } - - public long getValue() { - return value; - } - - public void setValue(long value) { - this.value = value; - } - - public int getJobType() { - return jobType; - } - - public void setJobType(int jobType) { - this.jobType = jobType; - } - - - -}
