AMBARI-19302 : removed contrib/views/hive folder and made necessary changes in pom.xml files (nitirajrathore)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/e423a65e Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/e423a65e Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/e423a65e Branch: refs/heads/trunk Commit: e423a65e5deca78d8068216a273d9d89d37756c9 Parents: 0bade7c Author: Nitiraj Rathore <[email protected]> Authored: Wed Dec 28 00:02:36 2016 +0530 Committer: Nitiraj Rathore <[email protected]> Committed: Wed Dec 28 15:01:52 2016 +0530 ---------------------------------------------------------------------- contrib/views/hive/pom.xml | 386 -------- .../apache/ambari/view/hive/BaseService.java | 54 -- .../apache/ambari/view/hive/HelpService.java | 132 --- .../apache/ambari/view/hive/HiveViewImpl.java | 50 - .../ambari/view/hive/PropertyValidator.java | 113 --- .../org/apache/ambari/view/hive/TestBean.java | 36 - .../backgroundjobs/BackgroundJobController.java | 90 -- .../view/hive/client/ColumnDescription.java | 48 - .../hive/client/ColumnDescriptionExtended.java | 103 -- .../hive/client/ColumnDescriptionShort.java | 72 -- .../ambari/view/hive/client/Connection.java | 740 -------------- .../view/hive/client/ConnectionFactory.java | 166 ---- .../apache/ambari/view/hive/client/Cursor.java | 243 ----- .../ambari/view/hive/client/DDLDelegator.java | 140 --- .../view/hive/client/HiveAuthCredentials.java | 31 - .../hive/client/HiveAuthRequiredException.java | 27 - .../ambari/view/hive/client/HiveCall.java | 120 --- .../client/HiveClientAuthRequiredException.java | 25 - .../view/hive/client/HiveClientException.java | 25 - .../hive/client/HiveClientRuntimeException.java | 25 - .../hive/client/HiveErrorStatusException.java | 30 - .../hive/client/HiveInvalidQueryException.java | 27 - .../hive/client/HttpBasicAuthInterceptor.java | 55 -- .../client/HttpKerberosRequestInterceptor.java | 72 -- .../hive/client/HttpRequestInterceptorBase.java | 88 -- .../ambari/view/hive/client/LogsCursor.java | 36 - .../org/apache/ambari/view/hive/client/Row.java | 74 -- .../view/hive/client/UserLocalConnection.java | 48 - .../client/UserLocalHiveAuthCredentials.java | 33 - .../apache/ambari/view/hive/client/Utils.java | 141 --- .../view/hive/client/ViewSessionState.java | 32 - .../view/hive/persistence/DataStoreStorage.java | 142 --- .../view/hive/persistence/IStorageFactory.java | 23 - .../persistence/InstanceKeyValueStorage.java | 135 --- .../view/hive/persistence/KeyValueStorage.java | 163 ---- .../hive/persistence/LocalKeyValueStorage.java | 73 -- .../persistence/PersistentConfiguration.java | 52 - .../ambari/view/hive/persistence/Storage.java | 77 -- .../utils/ContextConfigurationAdapter.java | 260 ----- .../persistence/utils/FilteringStrategy.java | 32 - .../view/hive/persistence/utils/Indexed.java | 36 - .../hive/persistence/utils/ItemNotFound.java | 43 - .../utils/OnlyOwnersFilteringStrategy.java | 38 - .../view/hive/persistence/utils/Owned.java | 36 - .../persistence/utils/PersonalResource.java | 22 - .../hive/persistence/utils/StorageFactory.java | 69 -- .../hive/resources/CRUDResourceManager.java | 131 --- .../view/hive/resources/IResourceManager.java | 37 - .../resources/PersonalCRUDResourceManager.java | 99 -- .../resources/SharedCRUDResourceManager.java | 44 - .../resources/browser/HiveBrowserService.java | 276 ------ .../view/hive/resources/files/FileResource.java | 70 -- .../view/hive/resources/files/FileService.java | 266 ----- .../view/hive/resources/jobs/Aggregator.java | 417 -------- .../resources/jobs/ConnectionController.java | 74 -- .../hive/resources/jobs/FileResourceShort.java | 55 -- .../jobs/IOperationHandleResourceManager.java | 40 - .../resources/jobs/JobResourceProvider.java | 113 --- .../view/hive/resources/jobs/JobService.java | 609 ------------ .../view/hive/resources/jobs/LogParser.java | 139 --- .../jobs/ModifyNotificationDelegate.java | 23 - .../ModifyNotificationInvocationHandler.java | 40 - .../jobs/NoOperationStatusSetException.java | 23 - .../jobs/OperationHandleController.java | 135 --- .../jobs/OperationHandleControllerFactory.java | 43 - .../jobs/OperationHandleResourceManager.java | 120 --- .../hive/resources/jobs/ProgressRetriever.java | 67 -- .../jobs/ResultsPaginationController.java | 240 ----- .../resources/jobs/StoredOperationHandle.java | 146 --- .../hive/resources/jobs/atsJobs/ATSParser.java | 248 ----- .../jobs/atsJobs/ATSParserFactory.java | 45 - .../jobs/atsJobs/ATSRequestsDelegate.java | 47 - .../jobs/atsJobs/ATSRequestsDelegateImpl.java | 175 ---- .../resources/jobs/atsJobs/HiveQueryId.java | 42 - .../hive/resources/jobs/atsJobs/IATSParser.java | 39 - .../hive/resources/jobs/atsJobs/TezDagId.java | 26 - .../resources/jobs/atsJobs/TezVertexId.java | 24 - .../view/hive/resources/jobs/rm/RMParser.java | 129 --- .../hive/resources/jobs/rm/RMParserFactory.java | 49 - .../resources/jobs/rm/RMRequestsDelegate.java | 31 - .../jobs/rm/RMRequestsDelegateImpl.java | 100 -- .../jobs/viewJobs/IJobControllerFactory.java | 23 - .../view/hive/resources/jobs/viewJobs/Job.java | 130 --- .../resources/jobs/viewJobs/JobController.java | 53 - .../jobs/viewJobs/JobControllerFactory.java | 41 - .../jobs/viewJobs/JobControllerImpl.java | 401 -------- .../hive/resources/jobs/viewJobs/JobImpl.java | 323 ------- .../hive/resources/jobs/viewJobs/JobInfo.java | 78 -- .../jobs/viewJobs/JobResourceManager.java | 107 -- .../resources/resources/FileResourceItem.java | 78 -- .../resources/FileResourceResourceManager.java | 65 -- .../resources/FileResourceResourceProvider.java | 110 --- .../resources/FileResourceService.java | 180 ---- .../hive/resources/savedQueries/SavedQuery.java | 96 -- .../savedQueries/SavedQueryResourceManager.java | 162 ---- .../SavedQueryResourceProvider.java | 113 --- .../savedQueries/SavedQueryService.java | 266 ----- .../ambari/view/hive/resources/udfs/UDF.java | 87 -- .../hive/resources/udfs/UDFResourceManager.java | 65 -- .../resources/udfs/UDFResourceProvider.java | 111 --- .../view/hive/resources/udfs/UDFService.java | 193 ---- .../view/hive/resources/uploads/CSVParams.java | 74 -- .../uploads/ColumnDescriptionImpl.java | 142 --- .../hive/resources/uploads/HiveFileType.java | 30 - .../hive/resources/uploads/TableDataReader.java | 111 --- .../view/hive/resources/uploads/TableInput.java | 51 - .../resources/uploads/UploadFromHdfsInput.java | 130 --- .../hive/resources/uploads/UploadService.java | 556 ----------- .../resources/uploads/parsers/DataParser.java | 66 -- .../uploads/parsers/EndOfDocumentException.java | 41 - .../hive/resources/uploads/parsers/IParser.java | 32 - .../resources/uploads/parsers/ParseOptions.java | 61 -- .../resources/uploads/parsers/ParseUtils.java | 213 ---- .../hive/resources/uploads/parsers/Parser.java | 161 ---- .../resources/uploads/parsers/PreviewData.java | 56 -- .../resources/uploads/parsers/RowIterator.java | 98 -- .../uploads/parsers/RowMapIterator.java | 29 - .../parsers/csv/commonscsv/CSVIterator.java | 57 -- .../parsers/csv/commonscsv/CSVParser.java | 88 -- .../parsers/csv/opencsv/OpenCSVIterator.java | 56 -- .../parsers/csv/opencsv/OpenCSVParser.java | 92 -- .../uploads/parsers/json/JSONIterator.java | 160 --- .../uploads/parsers/json/JSONParser.java | 85 -- .../uploads/parsers/xml/XMLIterator.java | 195 ---- .../uploads/parsers/xml/XMLParser.java | 100 -- .../uploads/query/DeleteQueryInput.java | 48 - .../uploads/query/InsertFromQueryInput.java | 92 -- .../resources/uploads/query/LoadQueryInput.java | 67 -- .../resources/uploads/query/QueryGenerator.java | 142 --- .../hive/resources/uploads/query/RowFormat.java | 57 -- .../hive/resources/uploads/query/TableInfo.java | 96 -- .../utils/BadRequestFormattedException.java | 27 - .../ambari/view/hive/utils/FilePaginator.java | 127 --- .../utils/HiveClientFormattedException.java | 26 - .../MisconfigurationFormattedException.java | 47 - .../hive/utils/NotFoundFormattedException.java | 27 - .../hive/utils/ServiceFormattedException.java | 107 -- .../view/hive/utils/SharedObjectsFactory.java | 187 ---- .../src/main/resources/ui/hive-web/.bowerrc | 4 - .../main/resources/ui/hive-web/.editorconfig | 34 - .../src/main/resources/ui/hive-web/.ember-cli | 27 - .../src/main/resources/ui/hive-web/.gitignore | 37 - .../src/main/resources/ui/hive-web/.jshintrc | 33 - .../src/main/resources/ui/hive-web/.travis.yml | 38 - .../src/main/resources/ui/hive-web/Brocfile.js | 54 -- .../src/main/resources/ui/hive-web/README.md | 14 - .../ui/hive-web/app/adapters/application.js | 54 -- .../ui/hive-web/app/adapters/database.js | 25 - .../ui/hive-web/app/adapters/file-upload.js | 30 - .../resources/ui/hive-web/app/adapters/file.js | 26 - .../ui/hive-web/app/adapters/upload-table.js | 89 -- .../src/main/resources/ui/hive-web/app/app.js | 34 - .../ui/hive-web/app/components/.gitkeep | 0 .../app/components/alert-message-widget.js | 35 - .../app/components/collapsible-widget.js | 38 - .../app/components/column-filter-widget.js | 56 -- .../app/components/date-range-widget.js | 98 -- .../hive-web/app/components/expander-widget.js | 36 - .../hive-web/app/components/extended-input.js | 50 - .../ui/hive-web/app/components/file-upload.js | 34 - .../ui/hive-web/app/components/input-header.js | 61 -- .../ui/hive-web/app/components/job-tr-view.js | 41 - .../ui/hive-web/app/components/modal-widget.js | 58 -- .../ui/hive-web/app/components/navbar-widget.js | 42 - .../ui/hive-web/app/components/no-bubbling.js | 31 - .../ui/hive-web/app/components/notify-widget.js | 31 - .../app/components/number-range-widget.js | 79 -- .../ui/hive-web/app/components/panel-widget.js | 30 - .../hive-web/app/components/popover-widget.js | 34 - .../hive-web/app/components/progress-widget.js | 30 - .../ui/hive-web/app/components/query-editor.js | 129 --- .../ui/hive-web/app/components/radio-button.js | 39 - .../ui/hive-web/app/components/select-widget.js | 66 -- .../ui/hive-web/app/components/tabs-widget.js | 68 -- .../ui/hive-web/app/components/tree-view.js | 23 - .../hive-web/app/components/typeahead-widget.js | 108 --- .../ui/hive-web/app/components/udf-tr-view.js | 81 -- .../ui/hive-web/app/components/upload-query.js | 32 - .../app/components/validated-text-field.js | 62 -- .../app/components/visualization-tabs-widget.js | 56 -- .../ui/hive-web/app/controllers/.gitkeep | 0 .../ui/hive-web/app/controllers/application.js | 26 - .../ui/hive-web/app/controllers/databases.js | 465 --------- .../ui/hive-web/app/controllers/history.js | 257 ----- .../ui/hive-web/app/controllers/index.js | 767 --------------- .../controllers/index/history-query/explain.js | 142 --- .../app/controllers/index/history-query/logs.js | 108 --- .../controllers/index/history-query/results.js | 238 ----- .../ui/hive-web/app/controllers/insert-udfs.js | 58 -- .../ui/hive-web/app/controllers/messages.js | 41 - .../ui/hive-web/app/controllers/modal-delete.js | 33 - .../app/controllers/modal-save-query.js | 42 - .../ui/hive-web/app/controllers/modal-save.js | 34 - .../ui/hive-web/app/controllers/open-queries.js | 400 -------- .../ui/hive-web/app/controllers/queries.js | 145 --- .../ui/hive-web/app/controllers/query-tabs.js | 176 ---- .../ui/hive-web/app/controllers/settings.js | 69 -- .../ui/hive-web/app/controllers/splash.js | 164 ---- .../ui/hive-web/app/controllers/tez-ui.js | 106 -- .../ui/hive-web/app/controllers/udfs.js | 143 --- .../ui/hive-web/app/controllers/upload-table.js | 965 ------------------- .../hive-web/app/controllers/visual-explain.js | 64 -- .../app/controllers/visualization-ui.js | 134 --- .../resources/ui/hive-web/app/helpers/.gitkeep | 0 .../ui/hive-web/app/helpers/all-uppercase.js | 25 - .../ui/hive-web/app/helpers/code-helper.js | 28 - .../ui/hive-web/app/helpers/date-binding.js | 27 - .../hive-web/app/helpers/format-column-type.js | 39 - .../ui/hive-web/app/helpers/log-helper.js | 28 - .../ui/hive-web/app/helpers/path-binding.js | 29 - .../hive-web/app/helpers/preformatted-string.js | 28 - .../ui/hive-web/app/helpers/tb-helper.js | 33 - .../main/resources/ui/hive-web/app/index.html | 42 - .../ui/hive-web/app/initializers/i18n.js | 348 ------- .../ui/hive-web/app/mixins/filterable.js | 106 -- .../ui/hive-web/app/mixins/sortable.js | 31 - .../resources/ui/hive-web/app/models/.gitkeep | 0 .../ui/hive-web/app/models/database.js | 25 - .../ui/hive-web/app/models/file-resource.js | 25 - .../resources/ui/hive-web/app/models/file.js | 26 - .../resources/ui/hive-web/app/models/job.js | 55 -- .../ui/hive-web/app/models/saved-query.js | 29 - .../resources/ui/hive-web/app/models/udf.js | 27 - .../main/resources/ui/hive-web/app/router.js | 50 - .../resources/ui/hive-web/app/routes/.gitkeep | 0 .../ui/hive-web/app/routes/application.js | 89 -- .../resources/ui/hive-web/app/routes/history.js | 29 - .../app/routes/index/history-query/explain.js | 28 - .../app/routes/index/history-query/index.js | 44 - .../app/routes/index/history-query/logs.js | 28 - .../app/routes/index/history-query/results.js | 28 - .../ui/hive-web/app/routes/index/index.js | 36 - .../ui/hive-web/app/routes/index/saved-query.js | 43 - .../resources/ui/hive-web/app/routes/loading.js | 22 - .../resources/ui/hive-web/app/routes/queries.js | 40 - .../resources/ui/hive-web/app/routes/splash.js | 61 -- .../resources/ui/hive-web/app/routes/udfs.js | 36 - .../ui/hive-web/app/serializers/database.js | 41 - .../ui/hive-web/app/serializers/file.js | 23 - .../ui/hive-web/app/services/database.js | 243 ----- .../resources/ui/hive-web/app/services/file.js | 59 -- .../ui/hive-web/app/services/history.js | 204 ---- .../ui/hive-web/app/services/job-progress.js | 102 -- .../resources/ui/hive-web/app/services/job.js | 56 -- .../app/services/ldap-authentication.js | 41 - .../ui/hive-web/app/services/notify.js | 113 --- .../ui/hive-web/app/services/session.js | 48 - .../ui/hive-web/app/services/settings.js | 193 ---- .../resources/ui/hive-web/app/styles/.gitkeep | 0 .../resources/ui/hive-web/app/styles/app.scss | 716 -------------- .../hive-web/app/styles/dropdown-submenu.scss | 65 -- .../ui/hive-web/app/styles/mixins.scss | 28 - .../ui/hive-web/app/styles/notifications.scss | 37 - .../ui/hive-web/app/styles/query-tabs.scss | 69 -- .../resources/ui/hive-web/app/styles/vars.scss | 21 - .../ui/hive-web/app/templates/.gitkeep | 0 .../ui/hive-web/app/templates/application.hbs | 26 - .../hive-web/app/templates/components/.gitkeep | 0 .../components/alert-message-widget.hbs | 28 - .../templates/components/collapsible-widget.hbs | 33 - .../components/column-filter-widget.hbs | 42 - .../templates/components/date-range-widget.hbs | 22 - .../templates/components/expander-widget.hbs | 31 - .../app/templates/components/input-header.hbs | 20 - .../app/templates/components/job-tr-view.hbs | 49 - .../app/templates/components/modal-widget.hbs | 35 - .../app/templates/components/navbar-widget.hbs | 45 - .../app/templates/components/no-bubbling.hbs | 19 - .../app/templates/components/notify-widget.hbs | 21 - .../components/number-range-widget.hbs | 23 - .../app/templates/components/panel-widget.hbs | 54 -- .../app/templates/components/popover-widget.hbs | 19 - .../templates/components/progress-widget.hbs | 23 - .../app/templates/components/query-editor.hbs | 19 - .../app/templates/components/select-widget.hbs | 39 - .../app/templates/components/tabs-widget.hbs | 41 - .../app/templates/components/tree-view.hbs | 28 - .../app/templates/components/udf-tr-view.hbs | 77 -- .../components/validated-text-field.hbs | 23 - .../components/visualization-tabs-widget.hbs | 27 - .../app/templates/databases-search-results.hbs | 54 -- .../hive-web/app/templates/databases-tree.hbs | 50 - .../ui/hive-web/app/templates/databases.hbs | 54 -- .../ui/hive-web/app/templates/history.hbs | 67 -- .../ui/hive-web/app/templates/index.hbs | 134 --- .../templates/index/history-query/explain.hbs | 27 - .../app/templates/index/history-query/logs.hbs | 19 - .../templates/index/history-query/results.hbs | 56 -- .../ui/hive-web/app/templates/insert-udfs.hbs | 46 - .../ui/hive-web/app/templates/loading.hbs | 19 - .../ui/hive-web/app/templates/logs.hbs | 19 - .../ui/hive-web/app/templates/message.hbs | 36 - .../ui/hive-web/app/templates/messages.hbs | 32 - .../ui/hive-web/app/templates/modal-delete.hbs | 21 - .../hive-web/app/templates/modal-save-query.hbs | 24 - .../ui/hive-web/app/templates/modal-save.hbs | 21 - .../ui/hive-web/app/templates/notification.hbs | 23 - .../ui/hive-web/app/templates/open-queries.hbs | 23 - .../ui/hive-web/app/templates/queries.hbs | 96 -- .../ui/hive-web/app/templates/query-tabs.hbs | 28 - .../ui/hive-web/app/templates/redirect.hbs | 19 - .../ui/hive-web/app/templates/settings.hbs | 70 -- .../ui/hive-web/app/templates/splash.hbs | 117 --- .../ui/hive-web/app/templates/tez-ui.hbs | 31 - .../ui/hive-web/app/templates/udfs.hbs | 53 - .../ui/hive-web/app/templates/upload-table.hbs | 296 ------ .../hive-web/app/templates/visual-explain.hbs | 93 -- .../hive-web/app/templates/visualization-ui.hbs | 37 - .../ui/hive-web/app/transforms/date.js | 49 - .../ui/hive-web/app/utils/constants.js | 230 ----- .../ui/hive-web/app/utils/dag-rules.js | 141 --- .../ui/hive-web/app/utils/functions.js | 139 --- .../resources/ui/hive-web/app/views/.gitkeep | 0 .../resources/ui/hive-web/app/views/index.js | 28 - .../resources/ui/hive-web/app/views/message.js | 36 - .../resources/ui/hive-web/app/views/messages.js | 37 - .../ui/hive-web/app/views/notification.js | 51 - .../resources/ui/hive-web/app/views/tez-ui.js | 37 - .../ui/hive-web/app/views/visual-explain.js | 461 --------- .../ui/hive-web/app/views/visualization-ui.js | 37 - .../main/resources/ui/hive-web/big_tables.js | 54 -- .../src/main/resources/ui/hive-web/bower.json | 28 - .../resources/ui/hive-web/config/environment.js | 70 -- .../src/main/resources/ui/hive-web/package.json | 47 - .../src/main/resources/ui/hive-web/testem.json | 10 - .../main/resources/ui/hive-web/tests/.jshintrc | 74 -- .../ui/hive-web/tests/blanket-options.js | 36 - .../ui/hive-web/tests/helpers/api-mock.js | 304 ------ .../ui/hive-web/tests/helpers/dbclick.js | 26 - .../ui/hive-web/tests/helpers/resolver.js | 29 - .../ui/hive-web/tests/helpers/start-app.js | 43 - .../resources/ui/hive-web/tests/img/spinner.gif | Bin 11435 -> 0 bytes .../main/resources/ui/hive-web/tests/index.html | 71 -- .../hive-web/tests/integration/database-test.js | 130 --- .../hive-web/tests/integration/history-test.js | 95 -- .../tests/integration/query-editor-test.js | 126 --- .../tests/integration/saved-queries-test.js | 152 --- .../hive-web/tests/integration/tez-ui-test.js | 49 - .../ui/hive-web/tests/integration/udfs-test.js | 109 --- .../resources/ui/hive-web/tests/test-helper.js | 24 - .../resources/ui/hive-web/tests/unit/.gitkeep | 0 .../hive-web/tests/unit/adapters/application.js | 48 - .../ui/hive-web/tests/unit/adapters/file.js | 39 - .../components/alert-message-widget-test.js | 91 -- .../unit/components/collapsible-widget-test.js | 46 - .../components/column-filter-widget-test.js | 138 --- .../unit/components/date-range-widget-test.js | 132 --- .../unit/components/expander-widget-test.js | 59 -- .../unit/components/extended-input-test.js | 81 -- .../tests/unit/components/job-tr-view-test.js | 62 -- .../tests/unit/components/modal-widget-test.js | 69 -- .../tests/unit/components/no-bubbling-test.js | 44 - .../unit/components/number-range-widget-test.js | 70 -- .../unit/components/popover-widget-test.js | 36 - .../unit/components/progress-widget-test.js | 40 - .../tests/unit/components/query-editor-test.js | 52 - .../tests/unit/components/select-widget-test.js | 158 --- .../tests/unit/components/tabs-wiget-test.js | 117 --- .../unit/components/typeahead-widget-test.js | 46 - .../tests/unit/components/udf-tr-view-test.js | 122 --- .../tests/unit/controllers/databases-test.js | 276 ------ .../tests/unit/controllers/history-test.js | 117 --- .../tests/unit/controllers/index-test.js | 328 ------- .../tests/unit/controllers/insert-udfs-test.js | 68 -- .../tests/unit/controllers/messages-test.js | 53 - .../tests/unit/controllers/open-queries-test.js | 102 -- .../tests/unit/controllers/queries-test.js | 35 - .../tests/unit/controllers/settings-test.js | 136 --- .../tests/unit/controllers/tez-ui-test.js | 98 -- .../tests/unit/controllers/udfs-test.js | 82 -- .../tests/unit/helpers/path-binding-test.js | 35 - .../hive-web/tests/unit/services/notify-test.js | 155 --- .../tests/unit/services/settings-test.js | 155 --- .../tests/unit/views/visual-explain-test.js | 106 -- .../main/resources/ui/hive-web/vendor/.gitkeep | 0 .../vendor/codemirror/codemirror-min.js | 17 - .../hive-web/vendor/codemirror/codemirror.css | 309 ------ .../ui/hive-web/vendor/codemirror/show-hint.css | 38 - .../ui/hive-web/vendor/codemirror/show-hint.js | 389 -------- .../ui/hive-web/vendor/codemirror/sql-hint.js | 192 ---- .../resources/ui/hive-web/vendor/dagre.min.js | 27 - .../src/main/resources/view.log4j.properties | 27 - contrib/views/hive/src/main/resources/view.xml | 347 ------- .../apache/ambari/view/hive/BaseHiveTest.java | 116 --- .../org/apache/ambari/view/hive/HDFSTest.java | 64 -- .../ambari/view/hive/PropertyValidatorTest.java | 112 --- .../ambari/view/hive/ServiceTestUtils.java | 63 -- .../BackgroundJobControllerTest.java | 77 -- .../ambari/view/hive/client/ConnectionTest.java | 73 -- .../ambari/view/hive/client/UtilsTest.java | 78 -- .../hive/resources/files/FileServiceTest.java | 273 ------ .../view/hive/resources/jobs/ATSParserTest.java | 512 ---------- .../hive/resources/jobs/AggregatorTest.java | 506 ---------- .../hive/resources/jobs/JobLDAPServiceTest.java | 159 --- .../hive/resources/jobs/JobServiceTest.java | 225 ----- .../view/hive/resources/jobs/LogParserTest.java | 73 -- .../resources/FileResourceServiceTest.java | 119 --- .../SavedQueryResourceManagerTest.java | 55 -- .../savedQueries/SavedQueryServiceTest.java | 191 ---- .../hive/resources/udfs/UDFServiceTest.java | 119 --- .../hive/resources/upload/CSVParserTest.java | 275 ------ .../resources/upload/DataParserCSVTest.java | 326 ------- .../resources/upload/DataParserJSONTest.java | 263 ----- .../resources/upload/DataParserXMLTest.java | 295 ------ .../hive/resources/upload/JsonParserTest.java | 147 --- .../resources/upload/OpenCSVParserTest.java | 333 ------- .../view/hive/resources/upload/OpenCSVTest.java | 259 ----- .../hive/resources/upload/ParseUtilsTest.java | 56 -- .../resources/upload/QueryGeneratorTest.java | 108 --- .../resources/upload/TableDataReaderTest.java | 127 --- .../hive/resources/upload/XMLParserTest.java | 138 --- .../ambari/view/hive/utils/HdfsApiMock.java | 86 -- .../utils/SeekableByteArrayInputStream.java | 71 -- contrib/views/pom.xml | 4 - pom.xml | 2 - 415 files changed, 39988 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/e423a65e/contrib/views/hive/pom.xml ---------------------------------------------------------------------- diff --git a/contrib/views/hive/pom.xml b/contrib/views/hive/pom.xml deleted file mode 100644 index efa49e1..0000000 --- a/contrib/views/hive/pom.xml +++ /dev/null @@ -1,386 +0,0 @@ -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You 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:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns="http://maven.apache.org/POM/4.0.0"; - xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> - <modelVersion>4.0.0</modelVersion> - <groupId>org.apache.ambari.contrib.views</groupId> - <artifactId>hive</artifactId> - <version>1.0.0.0-SNAPSHOT</version> - <name>Hive</name> - - <parent> - <groupId>org.apache.ambari.contrib.views</groupId> - <artifactId>ambari-contrib-views</artifactId> - <version>2.0.0.0-SNAPSHOT</version> - </parent> - - <dependencies> - <dependency> - <groupId>com.jayway.jsonpath</groupId> - <artifactId>json-path</artifactId> - <version>2.0.0</version> - </dependency> - <dependency> - <groupId>com.google.inject</groupId> - <artifactId>guice</artifactId> - </dependency> - <dependency> - <groupId>com.sun.jersey.contribs</groupId> - <artifactId>jersey-multipart</artifactId> - </dependency> - <dependency> - <groupId>com.sun.jersey</groupId> - <artifactId>jersey-client</artifactId> - </dependency> - <dependency> - <groupId>com.sun.jersey</groupId> - <artifactId>jersey-core</artifactId> - </dependency> - <dependency> - <groupId>com.sun.jersey</groupId> - <artifactId>jersey-json</artifactId> - </dependency> - <dependency> - <groupId>com.googlecode.json-simple</groupId> - <artifactId>json-simple</artifactId> - <version>1.1.1</version> - </dependency> - <dependency> - <groupId>commons-configuration</groupId> - <artifactId>commons-configuration</artifactId> - <version>1.6</version> - </dependency> - <dependency> - <groupId>com.opencsv</groupId> - <artifactId>opencsv</artifactId> - <version>3.8</version> - </dependency> - <dependency> - <groupId>org.apache.commons</groupId> - <artifactId>commons-collections4</artifactId> - <version>4.0</version> - </dependency> - <dependency> - <groupId>org.apache.ambari</groupId> - <artifactId>ambari-views</artifactId> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>com.google.code.gson</groupId> - <artifactId>gson</artifactId> - <version>2.2.2</version> - </dependency> - <dependency> - <groupId>javax.servlet</groupId> - <artifactId>javax.servlet-api</artifactId> - <version>3.0.1</version> - </dependency> - <dependency> - <groupId>org.slf4j</groupId> - <artifactId>slf4j-api</artifactId> - <version>1.7.5</version> - </dependency> - <dependency> - <groupId>org.apache.hadoop</groupId> - <artifactId>hadoop-hdfs</artifactId> - <version>${hadoop.version}</version> - <exclusions> - <exclusion> - <groupId>tomcat</groupId> - <artifactId>jasper-runtime</artifactId> - </exclusion> - </exclusions> - </dependency> - <dependency> - <groupId>org.apache.hadoop</groupId> - <artifactId>hadoop-common</artifactId> - <version>${hadoop.version}</version> - <exclusions> - <exclusion> - <groupId>tomcat</groupId> - <artifactId>jasper-runtime</artifactId> - </exclusion> - <exclusion> - <groupId>tomcat</groupId> - <artifactId>jasper-compiler</artifactId> - </exclusion> - </exclusions> - </dependency> - <dependency> - <groupId>org.apache.hadoop</groupId> - <artifactId>hadoop-mapreduce-client-common</artifactId> - <version>${hadoop.version}</version> - </dependency> - <dependency> - <groupId>org.apache.hadoop</groupId> - <artifactId>hadoop-mapreduce-client-core</artifactId> - <version>${hadoop.version}</version> - </dependency> - <dependency> - <groupId>org.apache.hadoop</groupId> - <artifactId>hadoop-yarn-client</artifactId> - <version>${hadoop.version}</version> - </dependency> - <dependency> - <groupId>javax.ws.rs</groupId> - <artifactId>javax.ws.rs-api</artifactId> - <version>2.0</version> - </dependency> - <dependency> - <groupId>org.apache.hive</groupId> - <artifactId>hive-service</artifactId> - <version>${hive-version}</version> - </dependency> - <dependency> - <groupId>org.apache.hive</groupId> - <artifactId>hive-common</artifactId> - <version>${hive-version}</version> - </dependency> - <dependency> - <groupId>org.apache.hive</groupId> - <artifactId>hive-shims</artifactId> - <version>${hive-version}</version> - </dependency> - <dependency> - <groupId>org.apache.hive</groupId> - <artifactId>hive-metastore</artifactId> - <version>${hive-version}</version> - </dependency> - <dependency> - <groupId>org.apache.hive</groupId> - <artifactId>hive-exec</artifactId> - <version>${hive-version}</version> - </dependency> - <dependency> - <groupId>commons-cli</groupId> - <artifactId>commons-cli</artifactId> - <version>1.2</version> - </dependency> - <dependency> - <groupId>commons-lang</groupId> - <artifactId>commons-lang</artifactId> - <version>2.2</version> - </dependency> - <dependency> - <groupId>org.apache.thrift</groupId> - <artifactId>libthrift</artifactId> - <version>0.9.0</version> - </dependency> - <dependency> - <groupId>junit</groupId> - <artifactId>junit</artifactId> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.easymock</groupId> - <artifactId>easymock</artifactId> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.apache.hadoop</groupId> - <artifactId>hadoop-minicluster</artifactId> - <version>${hadoop.version}</version> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.apache.ambari.contrib.views</groupId> - <artifactId>ambari-views-utils</artifactId> - <version>2.0.0.0-SNAPSHOT</version> - </dependency> - <dependency> - <groupId>commons-validator</groupId> - <artifactId>commons-validator</artifactId> - <version>1.4.0</version> - </dependency> - <dependency> - <groupId>commons-io</groupId> - <artifactId>commons-io</artifactId> - <version>2.4</version> - </dependency> - <dependency> - <groupId>org.apache.httpcomponents</groupId> - <artifactId>httpclient</artifactId> - <version>4.5.2</version> - </dependency> - <dependency> - <groupId>org.apache.httpcomponents</groupId> - <artifactId>httpcore</artifactId> - <version>4.4.3</version> - </dependency> - <dependency> - <groupId>org.apache.commons</groupId> - <artifactId>commons-csv</artifactId> - <version>1.1</version> - </dependency> - <dependency> - <groupId>org.apache.ambari.contrib.views</groupId> - <artifactId>ambari-views-commons</artifactId> - <version>2.0.0.0-SNAPSHOT</version> - </dependency> - </dependencies> - - <properties> - <ambari.dir>${project.parent.parent.parent.basedir}</ambari.dir> - <hive-version>1.0.0</hive-version> - <ambari.version>1.3.0.0-SNAPSHOT</ambari.version> - </properties> - <build> - <plugins> - - <!-- Building frontend --> - <plugin> - <groupId>com.github.eirslett</groupId> - <artifactId>frontend-maven-plugin</artifactId> - <version>0.0.16</version> - <configuration> - <nodeVersion>v4.5.0</nodeVersion> - <npmVersion>2.15.0</npmVersion> - <workingDirectory>src/main/resources/ui/hive-web/</workingDirectory> - </configuration> - <executions> - <execution> - <id>install node and npm</id> - <phase>generate-sources</phase> - <goals> - <goal>install-node-and-npm</goal> - </goals> - </execution> - <execution> - <id>npm install</id> - <phase>generate-sources</phase> - <goals> - <goal>npm</goal> - </goals> - <configuration> - <arguments>install --python="${project.basedir}/../src/main/unix/ambari-python-wrap" --unsafe-perm</arguments> - </configuration> - </execution> - </executions> - </plugin> - <plugin> - <artifactId>exec-maven-plugin</artifactId> - <groupId>org.codehaus.mojo</groupId> - <version>1.3.2</version> - <executions> - <execution> - <id>Hive build</id> - <phase>generate-sources</phase> - <goals> - <goal>exec</goal> - </goals> - <configuration> - <workingDirectory>${basedir}/src/main/resources/ui/hive-web</workingDirectory> - <executable>node/node</executable> - <arguments> - <argument>node_modules/.bin/ember</argument> - <argument>build</argument> - </arguments> - </configuration> - </execution> - </executions> - </plugin> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-compiler-plugin</artifactId> - <version>3.1</version> - <configuration> - <source>1.7</source> - <target>1.7</target> - </configuration> - </plugin> - <plugin> - <artifactId>maven-dependency-plugin</artifactId> - <executions> - <execution> - <phase>generate-resources</phase> - <goals> - <goal>copy-dependencies</goal> - </goals> - <configuration> - <outputDirectory>${project.build.directory}/lib</outputDirectory> - <includeScope>runtime</includeScope> - </configuration> - </execution> - <execution> - <id>copy-artifact</id> - <phase>package</phase> - <goals> - <goal>copy</goal> - </goals> - <configuration> - <artifactItems> - <artifactItem> - <groupId>${project.groupId}</groupId> - <artifactId>${project.artifactId}</artifactId> - <version>${project.version}</version> - <type>${project.packaging}</type> - </artifactItem> - </artifactItems> - <outputDirectory>${views.jars.dir.rel}</outputDirectory> - </configuration> - </execution> - </executions> - </plugin> - <plugin> - <groupId>org.vafer</groupId> - <artifactId>jdeb</artifactId> - <version>1.0.1</version> - <executions> - <execution> - <phase>none</phase> - <goals> - <goal>jdeb</goal> - </goals> - </execution> - </executions> - <configuration> - <submodules>false</submodules> - </configuration> - </plugin> - </plugins> - <resources> - <resource> - <directory>src/main/resources</directory> - <filtering>false</filtering> - <includes> - <include>META-INF/**/*</include> - <include>view.xml</include> - <include>view.log4j.properties</include> - </includes> - </resource> - <resource> - <directory>src/main/resources/ui/hive-web/dist</directory> - <filtering>false</filtering> - </resource> - <resource> - <directory>src/main/resources/ui/hive-web/bower_components/polestar</directory> - <filtering>false</filtering> - <targetPath>polestar</targetPath> - </resource> - <resource> - <directory>src/main/resources/ui/hive-web/bower_components/voyager</directory> - <filtering>false</filtering> - <targetPath>voyager</targetPath> - </resource> - <resource> - <targetPath>WEB-INF/lib</targetPath> - <filtering>false</filtering> - <directory>target/lib</directory> - </resource> - </resources> - </build> -</project> http://git-wip-us.apache.org/repos/asf/ambari/blob/e423a65e/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/BaseService.java ---------------------------------------------------------------------- diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/BaseService.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/BaseService.java deleted file mode 100644 index d29d758..0000000 --- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/BaseService.java +++ /dev/null @@ -1,54 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 org.apache.ambari.view.hive; - -import org.apache.ambari.view.ViewContext; -import org.apache.ambari.view.hive.utils.SharedObjectsFactory; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import javax.inject.Inject; - - -/** - * Parent service - */ -public class BaseService { - @Inject - protected ViewContext context; - - protected final static Logger LOG = - LoggerFactory.getLogger(BaseService.class); - - private SharedObjectsFactory sharedObjectsFactory; - public SharedObjectsFactory getSharedObjectsFactory() { - if (sharedObjectsFactory == null) { - sharedObjectsFactory = new SharedObjectsFactory(context); - } - return sharedObjectsFactory; - } - - public void setSharedObjectsFactory(SharedObjectsFactory sharedObjectsFactory) { - this.sharedObjectsFactory = sharedObjectsFactory; - } - - public BaseService() { -// Thread.currentThread().setContextClassLoader(null); - } -} http://git-wip-us.apache.org/repos/asf/ambari/blob/e423a65e/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HelpService.java ---------------------------------------------------------------------- diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HelpService.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HelpService.java deleted file mode 100644 index dcddf6d..0000000 --- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HelpService.java +++ /dev/null @@ -1,132 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 org.apache.ambari.view.hive; - -import org.apache.ambari.view.ViewContext; -import org.apache.ambari.view.ViewResourceHandler; -import org.apache.ambari.view.hive.resources.files.FileService; -import org.apache.ambari.view.hive.resources.jobs.atsJobs.ATSParserFactory; -import org.apache.ambari.view.hive.resources.jobs.atsJobs.ATSRequestsDelegate; -import org.apache.ambari.view.hive.resources.jobs.atsJobs.ATSRequestsDelegateImpl; -import org.json.simple.JSONObject; - -import javax.inject.Inject; -import javax.ws.rs.GET; -import javax.ws.rs.Path; -import javax.ws.rs.Produces; -import javax.ws.rs.WebApplicationException; -import javax.ws.rs.core.MediaType; -import javax.ws.rs.core.Response; -import java.io.IOException; - -/** - * Help service - */ -public class HelpService extends BaseService { - @Inject - ViewContext context; - - @Inject - protected ViewResourceHandler handler; - - /** - * Constructor - */ - public HelpService() { - super(); - } - - /** - * Version - * @return version - */ - @GET - @Path("/version") - @Produces(MediaType.TEXT_PLAIN) - public Response version(){ - return Response.ok("0.0.1-SNAPSHOT").build(); - } - - // ================================================================================ - // Smoke tests - // ================================================================================ - - /** - * HDFS Status - * @return status - */ - @GET - @Path("/hdfsStatus") - @Produces(MediaType.APPLICATION_JSON) - public Response hdfsStatus(){ - FileService.hdfsSmokeTest(context); - return getOKResponse(); - } - - /** - * HomeDirectory Status - * @return status - */ - @GET - @Path("/userhomeStatus") - @Produces(MediaType.APPLICATION_JSON) - public Response userhomeStatus (){ - FileService.userhomeSmokeTest(context); - return getOKResponse(); - } - - /** - * ATS Status - * @return status - */ - @GET - @Path("/atsStatus") - @Produces(MediaType.APPLICATION_JSON) - public Response atsStatus() { - try { - ATSRequestsDelegateImpl atsimpl = new ATSRequestsDelegateImpl(context, new ATSParserFactory(context).getATSUrl()); - atsimpl.checkATSStatus(); - return getOKResponse(); - }catch (IOException e){ - throw new WebApplicationException(e); - } - } - - private Response getOKResponse() { - JSONObject response = new JSONObject(); - response.put("message", "OK"); - response.put("trace", null); - response.put("status", "200"); - return Response.ok().entity(response).type(MediaType.APPLICATION_JSON).build(); - } - - /** - * Version - * @return version - */ - @GET - @Path("/test") - @Produces(MediaType.TEXT_PLAIN) - public Response testStorage(){ - TestBean test = new TestBean(); - test.someData = "hello world"; - getSharedObjectsFactory().getStorage().store(TestBean.class, test); - return Response.ok("OK").build(); - } -} http://git-wip-us.apache.org/repos/asf/ambari/blob/e423a65e/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HiveViewImpl.java ---------------------------------------------------------------------- diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HiveViewImpl.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HiveViewImpl.java deleted file mode 100644 index e28dfbf..0000000 --- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HiveViewImpl.java +++ /dev/null @@ -1,50 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 org.apache.ambari.view.hive; - -import org.apache.ambari.view.View; -import org.apache.ambari.view.ViewDefinition; -import org.apache.ambari.view.ViewInstanceDefinition; -import org.apache.ambari.view.hive.utils.SharedObjectsFactory; -import org.apache.ambari.view.utils.UserLocal; - - -public class HiveViewImpl implements View { - @Override - public void onDeploy(ViewDefinition definition) { - - } - - @Override - public void onCreate(ViewInstanceDefinition definition) { - - } - - @Override - public void onDestroy(ViewInstanceDefinition definition) { - SharedObjectsFactory.dropInstanceCache(definition.getInstanceName()); - } - - @Override - public void onUpdate(ViewInstanceDefinition definition) { - //drop all cached connection for instance - UserLocal.dropInstanceCache(definition.getInstanceName()); - SharedObjectsFactory.dropInstanceCache(definition.getInstanceName()); - } -} http://git-wip-us.apache.org/repos/asf/ambari/blob/e423a65e/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/PropertyValidator.java ---------------------------------------------------------------------- diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/PropertyValidator.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/PropertyValidator.java deleted file mode 100644 index e10dad3..0000000 --- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/PropertyValidator.java +++ /dev/null @@ -1,113 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 org.apache.ambari.view.hive; - -import org.apache.ambari.view.ClusterType; -import org.apache.ambari.view.ViewInstanceDefinition; -import org.apache.ambari.view.utils.ambari.ValidatorUtils; -import org.apache.ambari.view.validation.ValidationResult; -import org.apache.ambari.view.validation.Validator; - -public class PropertyValidator implements Validator { - - public static final String WEBHDFS_URL = "webhdfs.url"; - public static final String HIVE_PORT = "hive.port"; - public static final String YARN_ATS_URL = "yarn.ats.url"; - public static final String HIVE_AUTH = "hive.auth"; - - @Override - public ValidationResult validateInstance(ViewInstanceDefinition viewInstanceDefinition, ValidationContext validationContext) { - return null; - } - - @Override - public ValidationResult validateProperty(String property, ViewInstanceDefinition viewInstanceDefinition, ValidationContext validationContext) { - // Validate non cluster associated properties - if (property.equals(HIVE_AUTH)) { - String auth = viewInstanceDefinition.getPropertyMap().get(HIVE_AUTH); - - if (auth != null && !auth.isEmpty()) { - for(String param : auth.split(";")) { - String[] keyvalue = param.split("="); - if (keyvalue.length != 2) { - return new InvalidPropertyValidationResult(false, "Can not parse authentication param " + param + " in " + auth); - } - } - } - } - - // if associated with cluster(local or remote), no need to validate associated properties - ClusterType clusterType = viewInstanceDefinition.getClusterType(); - if (clusterType == ClusterType.LOCAL_AMBARI || clusterType == ClusterType.REMOTE_AMBARI) { - return ValidationResult.SUCCESS; - } - - // Cluster associated properties - if (property.equals(WEBHDFS_URL)) { - String webhdfsUrl = viewInstanceDefinition.getPropertyMap().get(WEBHDFS_URL); - if (!ValidatorUtils.validateHdfsURL(webhdfsUrl)) { - return new InvalidPropertyValidationResult(false, "Must be valid URL"); - } - } - - if (property.equals(HIVE_PORT)) { - String hivePort = viewInstanceDefinition.getPropertyMap().get(HIVE_PORT); - if (hivePort != null) { - try { - int port = Integer.valueOf(hivePort); - if (port < 1 || port > 65535) { - return new InvalidPropertyValidationResult(false, "Must be from 1 to 65535"); - } - } catch (NumberFormatException e) { - return new InvalidPropertyValidationResult(false, "Must be integer"); - } - } - } - - if (property.equals(YARN_ATS_URL)) { - String atsUrl = viewInstanceDefinition.getPropertyMap().get(YARN_ATS_URL); - if (!ValidatorUtils.validateHttpURL(atsUrl)) { - return new InvalidPropertyValidationResult(false, "Must be valid URL"); - } - } - - return ValidationResult.SUCCESS; - } - - public static class InvalidPropertyValidationResult implements ValidationResult { - private boolean valid; - private String detail; - - public InvalidPropertyValidationResult(boolean valid, String detail) { - this.valid = valid; - this.detail = detail; - } - - @Override - public boolean isValid() { - return valid; - } - - @Override - public String getDetail() { - return detail; - } - } - -} http://git-wip-us.apache.org/repos/asf/ambari/blob/e423a65e/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/TestBean.java ---------------------------------------------------------------------- diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/TestBean.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/TestBean.java deleted file mode 100644 index d298931..0000000 --- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/TestBean.java +++ /dev/null @@ -1,36 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 org.apache.ambari.view.hive; - -import org.apache.ambari.view.hive.persistence.utils.Indexed; - -public class TestBean implements Indexed { - public String someData; - public String id; - - @Override - public String getId() { - return id; - } - - @Override - public void setId(String id) { - this.id = id; - } -} http://git-wip-us.apache.org/repos/asf/ambari/blob/e423a65e/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/backgroundjobs/BackgroundJobController.java ---------------------------------------------------------------------- diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/backgroundjobs/BackgroundJobController.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/backgroundjobs/BackgroundJobController.java deleted file mode 100644 index ea8d51c..0000000 --- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/backgroundjobs/BackgroundJobController.java +++ /dev/null @@ -1,90 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 org.apache.ambari.view.hive.backgroundjobs; - -import org.apache.ambari.view.ViewContext; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.util.HashMap; -import java.util.Map; - -public class BackgroundJobController { - private final static Logger LOG = - LoggerFactory.getLogger(BackgroundJobController.class); - - private ViewContext context; - - protected BackgroundJobController(ViewContext context) { - this.context = context; - } - - private static Map<String, BackgroundJobController> viewSingletonObjects = new HashMap<String, BackgroundJobController>(); - public static BackgroundJobController getInstance(ViewContext context) { - if (!viewSingletonObjects.containsKey(context.getInstanceName())) - viewSingletonObjects.put(context.getInstanceName(), new BackgroundJobController(context)); - return viewSingletonObjects.get(context.getInstanceName()); - } - - private Map<String, Thread> jobs = new HashMap<String, Thread>(); - public void startJob(String key, Runnable runnable) { - LOG.info("Starting job with key : {}", key); - if (jobs.containsKey(key)) { - interrupt(key); - try { - jobs.get(key).join(); - } catch (InterruptedException ignored) { - } - } - Thread t = new Thread(runnable); - jobs.put(key, t); - t.start(); - } - - public Thread.State state(String key) { - if (!jobs.containsKey(key)) { - return Thread.State.TERMINATED; - } - - Thread.State state = jobs.get(key).getState(); - - if (state == Thread.State.TERMINATED) { - jobs.remove(key); - } - - return state; - } - - public boolean interrupt(String key) { - if (!jobs.containsKey(key)) { - return false; - } - - jobs.get(key).interrupt(); - return true; - } - - public boolean isInterrupted(String key) { - if (state(key) == Thread.State.TERMINATED) { - return true; - } - - return jobs.get(key).isInterrupted(); - } -} http://git-wip-us.apache.org/repos/asf/ambari/blob/e423a65e/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescription.java ---------------------------------------------------------------------- diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescription.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescription.java deleted file mode 100644 index a25571f..0000000 --- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescription.java +++ /dev/null @@ -1,48 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 org.apache.ambari.view.hive.client; - -public interface ColumnDescription { - enum DataTypes { - TINYINT, // - SMALLINT, // - INT, // - BIGINT, // - BOOLEAN, // - FLOAT, // - DOUBLE, // - STRING, // - BINARY, // -- (Note: Available in Hive 0.8.0 and later) - TIMESTAMP, // -- (Note: Available in Hive 0.8.0 and later) - DECIMAL, // -- (Note: Available in Hive 0.11.0 and later) - // DECIMAL,(precision, scale)Â -- (Note: Available in Hive 0.13.0 and later) Not included. - DATE, // -- (Note: Available in Hive 0.12.0 and later) - VARCHAR, // -- (Note: Available in Hive 0.12.0 and later) - CHAR, // -- (Note: Available in Hive 0.13.0 and later) - } - - public abstract String getName(); - public abstract void setName(String name); - - public abstract String getType(); - public abstract void setType(String type); - - public abstract int getPosition(); - public abstract void setPosition(int position); -} http://git-wip-us.apache.org/repos/asf/ambari/blob/e423a65e/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescriptionExtended.java ---------------------------------------------------------------------- diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescriptionExtended.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescriptionExtended.java deleted file mode 100644 index ab54e61..0000000 --- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescriptionExtended.java +++ /dev/null @@ -1,103 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 org.apache.ambari.view.hive.client; - -public class ColumnDescriptionExtended implements ColumnDescription { - private String name; - private String type; - private int position; - private String comment; - private boolean partitioned; - private boolean sortedBy; - private boolean clusteredBy; - - private ColumnDescriptionExtended(String name, String type, String comment, boolean partitioned, - boolean sortedBy, boolean clusteredBy, int position) { - setName(name); - setType(type); - setPosition(position); - setComment(comment); - setPartitioned(partitioned); - setSortedBy(sortedBy); - setClusteredBy(clusteredBy); - } - - public static ColumnDescription createExtendedColumnDescription(String name, String type, String comment, - boolean partitioned, boolean sortedBy, boolean clusteredBy, - int position) { - return new ColumnDescriptionExtended(name, type, comment, partitioned, sortedBy, clusteredBy, position); - } - - 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 int getPosition() { - return position; - } - - public void setPosition(int position) { - this.position = position; - } - - public String getComment() { - return comment; - } - - public void setComment(String comment) { - this.comment = comment; - } - - public boolean isPartitioned() { - return partitioned; - } - - public void setPartitioned(boolean partitioned) { - this.partitioned = partitioned; - } - - public boolean isSortedBy() { - return sortedBy; - } - - public void setSortedBy(boolean sortedBy) { - this.sortedBy = sortedBy; - } - - public boolean isClusteredBy() { - return clusteredBy; - } - - public void setClusteredBy(boolean clusteredBy) { - this.clusteredBy = clusteredBy; - } - -} http://git-wip-us.apache.org/repos/asf/ambari/blob/e423a65e/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescriptionShort.java ---------------------------------------------------------------------- diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescriptionShort.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescriptionShort.java deleted file mode 100644 index a6500aa..0000000 --- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/client/ColumnDescriptionShort.java +++ /dev/null @@ -1,72 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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 org.apache.ambari.view.hive.client; - -import java.util.ArrayList; - -public class ColumnDescriptionShort extends ArrayList<Object> implements ColumnDescription { - public static final int INITIAL_CAPACITY = 3; - public static final int NAME_INDEX = 0; - public static final int TYPE_INDEX = 1; - public static final int POSITION_INDEX = 2; - - private ColumnDescriptionShort(String name, String type, int position) { - super(INITIAL_CAPACITY); - this.add(null); - this.add(null); - this.add(null); - setName(name); - setType(type); - setPosition(position); - } - - public static ColumnDescription createShortColumnDescription(String name, String type, int position) { - return new ColumnDescriptionShort(name, type, position); - } - - @Override - public String getName() { - return (String) this.get(NAME_INDEX); - } - - @Override - public void setName(String name) { - this.set(NAME_INDEX, name); - } - - @Override - public String getType() { - return (String) this.get(TYPE_INDEX); - } - - @Override - public void setType(String type) { - this.set(TYPE_INDEX, type); - } - - @Override - public int getPosition() { - return (Integer) this.get(POSITION_INDEX); - } - - @Override - public void setPosition(int position) { - this.set(POSITION_INDEX, position); - } -}
