You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by db...@apache.org on 2016/05/31 19:44:21 UTC
[05/21] ambari git commit: AMBARI-16963: JDBC implementation of hive
view. (dipayanb)
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/messages-test.js
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/messages-test.js b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/messages-test.js
new file mode 100644
index 0000000..b0cdf16
--- /dev/null
+++ b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/messages-test.js
@@ -0,0 +1,53 @@
+/**
+ * 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.
+ */
+
+import Ember from 'ember';
+import constants from 'hive/utils/constants';
+import { moduleFor, test } from 'ember-qunit';
+
+moduleFor('controller:messages', 'MessagesController', {
+});
+
+test('Controller is initialized', function() {
+ var controller = this.subject();
+
+ ok(controller, 'Controller is initialized');
+});
+
+test('Controller action', function() {
+ var controller = this.subject({
+ notifyService: Ember.Object.create({
+ removeMessage: function(message) {
+ ok(1, 'removeMessage action called');
+ },
+ removeAllMessages: function() {
+ ok(1, 'removeAllMessages action called');
+ },
+ markMessagesAsSeen: function(message) {
+ ok(1, 'markMessagesAsSeen action called');
+ }
+ })
+ });
+
+ Ember.run(function() {
+ controller.send('removeMessage');
+ controller.send('removeAllMessages');
+ controller.send('markMessagesAsSeen');
+ });
+
+});
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/open-queries-test.js
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/open-queries-test.js b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/open-queries-test.js
new file mode 100644
index 0000000..c46134d
--- /dev/null
+++ b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/open-queries-test.js
@@ -0,0 +1,102 @@
+/**
+ * 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.
+ */
+
+import Ember from 'ember';
+import { moduleFor, test } from 'ember-qunit';
+
+moduleFor('controller:open-queries', 'OpenQueriesController', {
+ needs: [ 'controller:index/history-query/results',
+ 'controller:index/history-query/explain',
+ 'controller:index',
+ 'controller:settings',
+ 'service:file',
+ 'service:database'
+ ]
+});
+
+test('when initialized, controller sets the queryTabs.', function () {
+ expect(1);
+
+ var controller = this.subject();
+
+ ok(controller.get('queryTabs', 'queryTabs is initialized.'));
+});
+
+test('pushObject override creates a new queryFile mock and adds it to the collection if none provided.', function () {
+ expect(3);
+
+ var controller = this.subject();
+
+ var model = Ember.Object.create({
+ id: 5
+ });
+
+ controller.pushObject(null, model);
+
+ equal(controller.get('length'), 1, 'a new object was added to the open queries collection.');
+ equal(controller.objectAt(0).id, model.get('id'), 'the object id was set to the model id.');
+ equal(controller.objectAt(0).get('fileContent'), '', 'the object fileContent is initialized with empty string.');
+});
+
+test('getTabForModel retrieves the tab that has the id and the type equal to the ones of the given model.', function () {
+ expect(1);
+
+ var controller = this.subject();
+
+ var model = Ember.Object.create({
+ id: 1
+ });
+
+ controller.get('queryTabs').pushObject(Ember.Object.create({
+ id: model.get('id')
+ }));
+
+ equal(controller.getTabForModel(model), controller.get('queryTabs').objectAt(0), 'retrieves correct tab for the given model.');
+});
+
+test('getQueryForModel retrieves the query by id equality if a new record is given', function () {
+ expect(1);
+
+ var controller = this.subject();
+
+ var model = Ember.Object.create({
+ id: 1,
+ isNew: true
+ });
+
+ controller.pushObject(null, model);
+
+ equal(controller.getQueryForModel(model).get('id'), model.get('id'), 'a new record was given, the method retrieves the query by id equality');
+});
+
+test('getQueryForModel retrieves the query by record id equality with model queryFile path if a saved record is given', function () {
+ expect(1);
+
+ var controller = this.subject();
+
+ var model = Ember.Object.create({
+ id: 1,
+ queryFile: 'some/path'
+ });
+
+ controller.pushObject(Ember.Object.create({
+ id: model.get('queryFile')
+ }));
+
+ equal(controller.getQueryForModel(model).get('id'), model.get('queryFile'), 'a saved record was given, the method retrieves the query by id equality with record queryFile path.');
+});
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/queries-test.js
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/queries-test.js b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/queries-test.js
new file mode 100644
index 0000000..2578c33
--- /dev/null
+++ b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/queries-test.js
@@ -0,0 +1,35 @@
+/**
+ * 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.
+ */
+
+import Ember from 'ember';
+import { moduleFor, test } from 'ember-qunit';
+
+moduleFor('controller:queries', 'QueriesController', {
+ needs: [
+ 'controller:history',
+ 'controller:open-queries'
+ ]
+});
+
+test('controller is initialized', function() {
+ expect(1);
+
+ var component = this.subject();
+
+ equal(component.get('columns.length'), 4, 'Columns are initialized correctly');
+});
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/settings-test.js
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/settings-test.js b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/settings-test.js
new file mode 100644
index 0000000..366d18c
--- /dev/null
+++ b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/settings-test.js
@@ -0,0 +1,136 @@
+/**
+ * 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.
+ */
+
+import Ember from 'ember';
+import { moduleFor, test } from 'ember-qunit';
+
+moduleFor('controller:settings', 'SettingsController', {
+ needs: [
+ 'controller:databases',
+ 'controller:index',
+ 'controller:open-queries',
+ 'controller:index/history-query/results',
+ 'controller:index/history-query/explain',
+ 'controller:udfs',
+ 'controller:index/history-query/logs',
+ 'controller:visual-explain',
+ 'controller:tez-ui',
+ 'adapter:database',
+ 'adapter:application',
+ 'service:settings',
+ 'service:notify',
+ 'service:database',
+ 'service:file',
+ 'service:session',
+ 'service:job',
+ 'service:job-progress'
+ ]
+});
+
+test('can add a setting', function() {
+ var controller = this.subject();
+
+ ok(!controller.get('settings.length'), 'No initial settings');
+
+ Ember.run(function() {
+ controller.send('add');
+ });
+
+ equal(controller.get('settings.length'), 1, 'Can add settings');
+});
+
+test('validate', function() {
+ var predefinedSettings = [
+ {
+ name: 'some.key',
+ validate: new RegExp(/^\d+$/) // digits
+ }
+ ];
+
+ var controller = this.subject({
+ predefinedSettings: predefinedSettings
+ });
+
+ controller.set('openQueries.update', function () {
+ var defer = Ember.RSVP.defer();
+ defer.resolve();
+
+ return defer.promise;
+ });
+
+ var settings = [
+ Ember.Object.create({key: { name: 'some.key' }, value: 'value'}),
+ Ember.Object.create({key: { name: 'some.key' }, value: '123'})
+ ];
+
+ Ember.run(function() {
+ controller.set('settings', settings);
+ });
+
+ var currentSettings = controller.get('settings');
+ ok(!currentSettings.get('firstObject.valid'), "First setting doesn\' pass validataion");
+ ok(currentSettings.get('lastObject.valid'), 'Second setting passes validation');
+});
+
+test('Actions', function(assert) {
+ assert.expect(5);
+
+ var settingsService = Ember.Object.create({
+ add: function() {
+ assert.ok(true, 'add called');
+ },
+ remove: function(setting) {
+ assert.ok(setting, 'Setting param is sent');
+ },
+ createKey: function(name) {
+ assert.ok(name, 'Name param is sent');
+ },
+ removeAll: function() {
+ assert.ok(true, 'removeAll called');
+ },
+ saveDefaultSettings: function() {
+ assert.ok(true, 'saveDefaultSettings called');
+ }
+ });
+
+ var controller = this.subject();
+ controller.set('settingsService', settingsService);
+
+ Ember.run(function() {
+ controller.send('add');
+ controller.send('remove', {});
+ controller.send('addKey', {});
+ controller.send('removeAll');
+ controller.send('saveDefaultSettings');
+ });
+});
+
+
+test('Excluded settings', function(assert) {
+ var controller = this.subject();
+
+ console.log(controller.get('predefinedSettings'));
+ assert.equal(controller.get('excluded').length, 0, 'Initially there are no excluded settings');
+
+ Ember.run(function() {
+ controller.get('settings').pushObject(Ember.Object.create({ key: { name: 'hive.tez.container.size' }}));
+ controller.get('settings').pushObject(Ember.Object.create({ key: { name: 'hive.prewarm.enabled' }}));
+ });
+
+ assert.equal(controller.get('excluded').length, 2, 'Two settings are excluded');
+});
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/tez-ui-test.js
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/tez-ui-test.js b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/tez-ui-test.js
new file mode 100644
index 0000000..fdf4a89
--- /dev/null
+++ b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/tez-ui-test.js
@@ -0,0 +1,98 @@
+/**
+ * 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.
+ */
+
+import Ember from 'ember';
+import DS from 'ember-data';
+import { moduleFor, test } from 'ember-qunit';
+
+var container;
+
+moduleFor('controller:tez-ui', 'TezUIController', {
+ needs: [
+ 'controller:index',
+ 'service:job',
+ 'service:file',
+ 'controller:open-queries',
+ 'controller:databases',
+ 'controller:udfs',
+ 'controller:index/history-query/logs',
+ 'controller:index/history-query/results',
+ 'controller:index/history-query/explain',
+ 'controller:settings',
+ 'controller:visual-explain',
+ 'adapter:database',
+ 'service:database',
+ 'service:notify',
+ 'service:job-progress',
+ 'service:session',
+ 'service:settings'
+ ],
+
+ setup: function() {
+ container = new Ember.Container();
+ container.register('store:main', Ember.Object.extend({
+ find: Ember.K
+ }));
+ }
+});
+
+test('controller is initialized properly.', function () {
+ expect(1);
+
+ var controller = this.subject();
+
+ ok(controller);
+});
+
+test('dagId returns false if there is no tez view available', function() {
+ var controller = this.subject();
+
+ ok(!controller.get('dagId'), 'dagId is false without a tez view available');
+});
+
+// test('dagId returns the id if there is view available', function() {
+// var controller = this.subject({
+// });
+
+// Ember.run(function() {
+// controller.set('index.model', Ember.Object.create({
+// id: 2,
+// dagId: 3
+// }));
+
+// controller.set('isTezViewAvailable', true);
+// });
+
+// equal(controller.get('dagId'), 3, 'dagId is truthy');
+// });
+
+test('dagURL returns false if no dag id is available', function() {
+ var controller = this.subject();
+
+ ok(!controller.get('dagURL'), 'dagURL is false');
+});
+
+test('dagURL returns the url if dag id is available', function() {
+ var controller = this.subject({
+ tezViewURL: '1',
+ tezDagPath: '2',
+ dagId: '3'
+ });
+
+ equal(controller.get('dagURL'), '123');
+});
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/udfs-test.js
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/udfs-test.js b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/udfs-test.js
new file mode 100644
index 0000000..5bd369e
--- /dev/null
+++ b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/controllers/udfs-test.js
@@ -0,0 +1,60 @@
+/**
+ * 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.
+ */
+
+import Ember from 'ember';
+import { moduleFor, test } from 'ember-qunit';
+
+moduleFor('controller:udfs', 'UdfsController', {});
+
+test('controller is initialized', function() {
+ expect(3);
+
+ var component = this.subject();
+
+ equal(component.get('columns.length'), 2, 'Columns are initialized correctly');
+ ok(component.get('sortAscending'), 'Sort ascending is true');
+ equal(component.get('sortProperties.length'), 0, 'sortProperties is empty');
+});
+
+test('sort', function() {
+ expect(2);
+
+ var component = this.subject();
+
+ Ember.run(function () {
+ component.send('sort', 'prop');
+ });
+
+ ok(component.get('sortAscending'), 'New sort prop sortAscending is set to true');
+ equal(component.get('sortProperties').objectAt(0), "prop", 'sortProperties is set to prop');
+});
+
+test('add', function() {
+ expect(1);
+
+ var store = {
+ createRecord: function(name) {
+ ok(name, 'store.createRecord called');
+ }
+ };
+ var component = this.subject({ store: store });
+
+ Ember.run(function () {
+ component.send('add');
+ });
+});
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/helpers/path-binding-test.js
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/helpers/path-binding-test.js b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/helpers/path-binding-test.js
new file mode 100644
index 0000000..22ba58a
--- /dev/null
+++ b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/helpers/path-binding-test.js
@@ -0,0 +1,35 @@
+/**
+ * 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.
+ */
+
+import {
+ pathBinding
+} from 'hive/helpers/path-binding';
+
+import Ember from 'ember';
+
+module('PathBindingHelper');
+
+// Replace this with your real tests.
+test('it should retrieve property value for a given object.', function() {
+ var obj = Ember.Object.extend({
+ name: 'some name'
+ }).create();
+
+ var result = pathBinding(obj, 'name');
+ equal(result, obj.get('name'));
+});
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/services/notify-test.js
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/services/notify-test.js b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/services/notify-test.js
new file mode 100644
index 0000000..383bf31
--- /dev/null
+++ b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/services/notify-test.js
@@ -0,0 +1,155 @@
+/**
+ * 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.
+ */
+
+import Ember from 'ember';
+import { moduleFor, test } from 'ember-qunit';
+
+moduleFor('service:notify', 'NotifyService');
+
+test('Service initialized correctly', function () {
+ expect(3);
+
+ var service = this.subject();
+ service.removeAllMessages();
+ service.markMessagesAsSeen();
+
+ equal(service.get('messages.length'), 0, 'No messages');
+ equal(service.get('notifications.length'), 0, 'No notifications');
+ equal(service.get('unseenMessages.length'), 0, 'No unseenMessages');
+});
+
+test('Can add notification', function() {
+ expect(3);
+ var service = this.subject();
+
+ service.add('notif', 'message', 'body');
+
+ equal(service.get('messages.length'), 1, 'one message added');
+ equal(service.get('notifications.length'), 1, 'one notifications added');
+ equal(service.get('unseenMessages.length'), 1, 'one unseenMessages added');
+});
+
+test('Can add info notification', function() {
+ expect(1);
+ var service = this.subject();
+
+ service.info('message', 'body');
+ equal(service.get('messages.lastObject.type.typeClass'), 'alert-info', 'Info notification added');
+});
+
+test('Can add warn notification', function() {
+ expect(1);
+ var service = this.subject();
+
+ service.warn('message', 'body');
+ equal(service.get('messages.lastObject.type.typeClass'), 'alert-warning', 'Warn notification added');
+});
+
+test('Can add error notification', function() {
+ expect(1);
+ var service = this.subject();
+
+ service.error('message', 'body');
+ equal(service.get('messages.lastObject.type.typeClass'), 'alert-danger', 'Error notification added');
+});
+
+test('Can add success notification', function() {
+ expect(1);
+ var service = this.subject();
+
+ service.success('message', 'body');
+ equal(service.get('messages.lastObject.type.typeClass'), 'alert-success', 'Success notification added');
+});
+
+test('Can format message body', function() {
+ expect(3);
+
+ var objectBody = {
+ k1: 'v1',
+ k2: 'v2'
+ };
+ var formatted = "\n\nk1:\nv1\n\nk2:\nv2";
+ var service = this.subject();
+
+ ok(!service.formatMessageBody(), 'Return nothing if no body is passed');
+ equal(service.formatMessageBody('some string'), 'some string', 'Return the body if it is a string');
+ equal(service.formatMessageBody(objectBody), formatted, 'Parse the keys and return a string if it is an object');
+});
+
+test('Can removeMessage', function() {
+ expect(4);
+
+ var service = this.subject();
+ var messagesCount = service.get('messages.length');
+ var notificationCount = service.get('notifications.length');
+
+ service.add('type', 'message', 'body');
+
+ equal(service.get('messages.length'), messagesCount + 1, 'Message added');
+ equal(service.get('notifications.length'), notificationCount + 1, 'Notification added');
+
+ var message = service.get('messages.lastObject');
+ service.removeMessage(message);
+
+ equal(service.get('messages.length'), messagesCount, 'Message removed');
+ equal(service.get('notifications.length'), notificationCount, 'Notification removed');
+});
+
+test('Can removeNotification', function() {
+ expect(2);
+
+ var service = this.subject();
+ var notificationCount = service.get('notifications.length');
+
+ service.add('type', 'message', 'body');
+
+ equal(service.get('notifications.length'), notificationCount + 1, 'Notification added');
+
+ var notification = service.get('notifications.lastObject');
+ service.removeNotification(notification);
+
+ equal(service.get('notifications.length'), notificationCount, 'Notification removed');
+});
+
+test('Can removeAllMessages', function() {
+ expect(2);
+
+ var service = this.subject();
+
+ service.add('type', 'message', 'body');
+ service.add('type', 'message', 'body');
+ service.add('type', 'message', 'body');
+
+ ok(service.get('messages.length'), 'Messages are present');
+ service.removeAllMessages();
+ equal(service.get('messages.length'), 0, 'No messages found');
+});
+
+test('Can markMessagesAsSeen', function() {
+ expect(2);
+
+ var service = this.subject();
+
+ service.add('type', 'message', 'body');
+ service.add('type', 'message', 'body');
+ service.add('type', 'message', 'body');
+
+ ok(service.get('unseenMessages.length'), 'There are unseen messages');
+ service.markMessagesAsSeen();
+ equal(service.get('unseenMessages.length'), 0, 'No unseen messages');
+});
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/services/settings-test.js
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/services/settings-test.js b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/services/settings-test.js
new file mode 100644
index 0000000..cb99882
--- /dev/null
+++ b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/services/settings-test.js
@@ -0,0 +1,155 @@
+/**
+ * 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.
+ */
+
+import Ember from 'ember';
+import { moduleFor, test } from 'ember-qunit';
+
+moduleFor('service:settings', 'SettingsService');
+
+test('Init', function(assert) {
+ var service = this.subject();
+ assert.ok(service);
+});
+
+test('Can create a setting object', function(assert) {
+ assert.expect(2);
+
+ var service = this.subject();
+
+ var setting = service._createSetting('sName', 'sValue');
+
+ assert.equal(setting.get('key.name'), 'sName', 'Settign has the correct name');
+ assert.equal(setting.get('value'), 'sValue', 'Settign has the correct value');
+
+ service.removeAll();
+});
+
+test('Can create default settings', function(assert) {
+ assert.expect(2);
+
+ var service = this.subject();
+
+ var settings = {
+ 'sName1': 'sValue1',
+ 'sName2': 'sValue2',
+ 'sName3': 'sValue3'
+ };
+
+ service._createDefaultSettings();
+
+ assert.equal(service.get('settings.length'), 0, '0 settings created');
+
+ service._createDefaultSettings(settings);
+
+ assert.equal(service.get('settings.length'), 3, '3 settings created');
+
+ service.removeAll();
+});
+
+test('Can add a setting', function(assert) {
+ assert.expect(2);
+
+ var service = this.subject();
+ assert.equal(service.get('settings.length'), 0, 'No settings');
+ service.add();
+ service.add();
+ assert.equal(service.get('settings.length'), 2, '2 settings added');
+
+ service.removeAll();
+});
+
+test('Can remove a setting', function(assert) {
+ assert.expect(2);
+
+ var service = this.subject();
+
+ service.add();
+ service.add();
+
+ assert.equal(service.get('settings.length'), 2, '2 settings added');
+ var firstSetting = service.get('settings.firstObject');
+ service.remove(firstSetting);
+ assert.equal(service.get('settings.length'), 1, 'Setting removed');
+
+ service.removeAll();
+});
+
+test('Can create key', function(assert) {
+ assert.expect(2);
+ var service = this.subject();
+
+ assert.ok(!service.get('predefinedSettings').findBy('name', 'new.key.name'), 'Key doesn\'t exist');
+
+ var setting = service._createSetting();
+ setting.set('key', null);
+ service.get('settings').pushObject(setting);
+ service.createKey('new.key.name');
+
+ assert.ok(service.get('predefinedSettings').findBy('name', 'new.key.name'), 'Key created');
+
+ service.removeAll();
+});
+
+test('Can get settings string', function(assert) {
+ var service = this.subject();
+
+ var noSettings = service.getSettings();
+ assert.equal(noSettings, "", 'An empty string is returned if there are no settings');
+
+ var settings = {
+ 'sName1': 'sValue1',
+ 'sName2': 'sValue2'
+ };
+
+ service._createDefaultSettings(settings);
+
+ var expectedWithSettings = "set sName1=sValue1;\nset sName2=sValue2;\n--Global Settings--\n\n";
+ var withSettings = service.getSettings();
+
+ assert.equal(withSettings, expectedWithSettings, 'Returns correct string');
+});
+
+test('It can parse global settings', function(assert) {
+ var service = this.subject();
+
+ assert.ok(!service.parseGlobalSettings(), 'It returns if query or model is not passed');
+
+ var settings = {
+ 'sName1': 'sValue1',
+ 'sName2': 'sValue2'
+ };
+
+
+ var globalSettingsString = "set sName1=sValue1;\nset sName2=sValue2;\n--Global Settings--\n\n";
+
+ var model = Ember.Object.create({
+ globalSettings: globalSettingsString
+ });
+
+ var query = Ember.Object.create({
+ fileContent: globalSettingsString + "{{match}}"
+ });
+
+ assert.ok(!service.parseGlobalSettings(query, model), 'It returns if current settings don\'t match models global settings');
+
+ service._createDefaultSettings(settings);
+
+ service.parseGlobalSettings(query, model);
+
+ assert.equal(query.get('fileContent'), "{{match}}", 'It parsed global settings');
+});
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/views/visual-explain-test.js
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/views/visual-explain-test.js b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/views/visual-explain-test.js
new file mode 100644
index 0000000..2fa23df
--- /dev/null
+++ b/contrib/views/hive-next/src/main/resources/ui/hive-web/tests/unit/views/visual-explain-test.js
@@ -0,0 +1,106 @@
+/**
+ * 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.
+ */
+
+import {
+ moduleFor,
+ test
+} from 'ember-qunit';
+
+var view;
+
+moduleFor('view:visual-explain', 'VisualExplainView', {
+ setup: function() {
+ var controller = Ember.Controller.extend({}).create();
+
+ view = this.subject({
+ controller: controller
+ });
+
+ Ember.run(function() {
+ view.appendTo('#ember-testing');
+ });
+ },
+
+ teardown: function() {
+ Ember.run(view, view.destroy);
+ },
+});
+
+//select count (*) from power
+var selectCountJson = {"STAGE PLANS":{"Stage-1":{"Tez":{"DagName:":"hive_20150608120000_b930a285-dc6a-49b7-86b6-8bee5ecdeacd:96","Vertices:":{"Reducer 2":{"Reduce Operator Tree:":{"Group By Operator":{"mode:":"mergepartial","aggregations:":["count(VALUE._col0)"],"outputColumnNames:":["_col0"],"children":{"Select Operator":{"expressions:":"_col0 (type: bigint)","outputColumnNames:":["_col0"],"children":{"File Output Operator":{"Statistics:":"Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: COMPLETE","compressed:":"false","table:":{"serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat"}}},"Statistics:":"Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: COMPLETE"}},"Statistics:":"Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: COMPLETE"}}},"Map 1":{"Map Operator Tree:":[{"TableScan":{"alias:":"power","childre
n":{"Select Operator":{"children":{"Group By Operator":{"mode:":"hash","aggregations:":["count()"],"outputColumnNames:":["_col0"],"children":{"Reduce Output Operator":{"sort order:":"","value expressions:":"_col0 (type: bigint)","Statistics:":"Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: COMPLETE"}},"Statistics:":"Num rows: 1 Data size: 8 Basic stats: COMPLETE Column stats: COMPLETE"}},"Statistics:":"Num rows: 0 Data size: 132960632 Basic stats: PARTIAL Column stats: COMPLETE"}},"Statistics:":"Num rows: 0 Data size: 132960632 Basic stats: PARTIAL Column stats: COMPLETE"}}]}},"Edges:":{"Reducer 2":{"parent":"Map 1","type":"SIMPLE_EDGE"}}}},"Stage-0":{"Fetch Operator":{"limit:":"-1","Processor Tree:":{"ListSink":{}}}}},"STAGE DEPENDENCIES":{"Stage-1":{"ROOT STAGE":"TRUE"},"Stage-0":{"DEPENDENT STAGES":"Stage-1"}}};
+
+//select power.adate, power.atime from power join power2 on power.adate = power2.adate
+var joinJson = {"STAGE PLANS":{"Stage-1":{"Tez":{"DagName:":"hive_20150608124141_acde7f09-6b72-4ad4-88b0-807d499724eb:107","Vertices:":{"Reducer 2":{"Reduce Operator Tree:":{"Merge Join Operator":{"outputColumnNames:":["_col0","_col1"],"children":{"Select Operator":{"expressions:":"_col0 (type: string), _col1 (type: string)","outputColumnNames:":["_col0","_col1"],"children":{"File Output Operator":{"Statistics:":"Num rows: 731283 Data size: 73128349 Basic stats: COMPLETE Column stats: NONE","compressed:":"false","table:":{"serde:":"org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe","input format:":"org.apache.hadoop.mapred.TextInputFormat","output format:":"org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat"}}},"Statistics:":"Num rows: 731283 Data size: 73128349 Basic stats: COMPLETE Column stats: NONE"}},"Statistics:":"Num rows: 731283 Data size: 73128349 Basic stats: COMPLETE Column stats: NONE","condition map:":[{"":"Inner Join 0 to 1"}],"condition expressions:":{"1":"",
"0":"{KEY.reducesinkkey0} {VALUE._col0}"}}}},"Map 1":{"Map Operator Tree:":[{"TableScan":{"filterExpr:":"adate is not null (type: boolean)","alias:":"power2","children":{"Filter Operator":{"predicate:":"adate is not null (type: boolean)","children":{"Reduce Output Operator":{"Map-reduce partition columns:":"adate (type: string)","sort order:":"+","Statistics:":"Num rows: 664803 Data size: 66480316 Basic stats: COMPLETE Column stats: NONE","key expressions:":"adate (type: string)"}},"Statistics:":"Num rows: 664803 Data size: 66480316 Basic stats: COMPLETE Column stats: NONE"}},"Statistics:":"Num rows: 1329606 Data size: 132960632 Basic stats: COMPLETE Column stats: NONE"}}]},"Map 3":{"Map Operator Tree:":[{"TableScan":{"filterExpr:":"adate is not null (type: boolean)","alias:":"power","children":{"Filter Operator":{"predicate:":"adate is not null (type: boolean)","children":{"Reduce Output Operator":{"Map-reduce partition columns:":"adate (type: string)","sort order:":"+","value expr
essions:":"atime (type: string)","Statistics:":"Num rows: 332402 Data size: 66480416 Basic stats: COMPLETE Column stats: NONE","key expressions:":"adate (type: string)"}},"Statistics:":"Num rows: 332402 Data size: 66480416 Basic stats: COMPLETE Column stats: NONE"}},"Statistics:":"Num rows: 664803 Data size: 132960632 Basic stats: COMPLETE Column stats: NONE"}}]}},"Edges:":{"Reducer 2":[{"parent":"Map 1","type":"SIMPLE_EDGE"},{"parent":"Map 3","type":"SIMPLE_EDGE"}]}}},"Stage-0":{"Fetch Operator":{"limit:":"-1","Processor Tree:":{"ListSink":{}}}}},"STAGE DEPENDENCIES":{"Stage-1":{"ROOT STAGE":"TRUE"},"Stage-0":{"DEPENDENT STAGES":"Stage-1"}}};
+
+// Replace this with your real tests.
+test('it renders dag when controller.json changes.', function (assert) {
+ assert.expect(1);
+
+ view.renderDag = function () {
+ assert.ok(true, 'dag rendering has been called on json set.');
+ };
+
+ view.set('controller.json', selectCountJson);
+});
+
+test('renderDag generates correct number of nodes and edges.', function (assert) {
+ assert.expect(4);
+
+ Ember.run(function () {
+ view.set('controller.json', selectCountJson);
+
+ assert.equal(view.get('graph').nodes().length, 4);
+ assert.equal(view.get('graph').edges().length, 3);
+
+ view.set('controller.json', joinJson);
+
+ assert.equal(view.get('graph').nodes().length, 7);
+ assert.equal(view.get('graph').edges().length, 6);
+ });
+});
+
+test('progress gets updated for each node.', function (assert) {
+ expect(2);
+
+ Ember.run(function () {
+ view.set('controller.json', selectCountJson);
+
+ var targetNode;
+ var verticesGroups = view.get('verticesGroups');
+
+ verticesGroups.some(function (verticesGroup) {
+ var node = verticesGroup.contents.findBy('label', 'Map 1');
+
+ if (node) {
+ targetNode = node;
+ return true;
+ }
+ });
+
+ assert.equal(targetNode.get('progress'), undefined, 'initial progress is falsy.');
+
+ view.set('controller.verticesProgress', [
+ Ember.Object.create({
+ name: 'Map 1',
+ value: 1
+ })
+ ]);
+
+ assert.equal(targetNode.get('progress'), 1, 'progress gets updated to given value.');
+ });
+});
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ambari/blob/9dc382a5/contrib/views/hive-next/src/main/resources/ui/hive-web/vendor/.gitkeep
----------------------------------------------------------------------
diff --git a/contrib/views/hive-next/src/main/resources/ui/hive-web/vendor/.gitkeep b/contrib/views/hive-next/src/main/resources/ui/hive-web/vendor/.gitkeep
new file mode 100644
index 0000000..e69de29