| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319 |
- // Licensed to Cloudera, Inc. under one
- // or more contributor license agreements. See the NOTICE file
- // distributed with this work for additional information
- // regarding copyright ownership. Cloudera, Inc. 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.
- var AppViewModel = function() {
- var self = this;
- self.station = ko.observable("");
- self.pageTitle = ko.observable("");
- self.focusModel = ko.observable();
- self.cluster = ko.observable("");
- self.cluster.subscribe(function() {
- app.views.tabledata.name('');
- });
- self.clusters = ko.observableArray();
- self.clusterNames = ko.computed(function() {
- return ko.utils.arrayMap(self.clusters(), function (cluster_config) {
- return cluster_config.name;
- });
- });
- self.search = new tagsearch();
- self.views = {
- tables: new DataTableViewModel({columns:['Table Name', 'Enabled'], el: 'views.tables', reload: function(callback) {
- var d_self = this;
- d_self.items.removeAll();
- API.queryCluster("getTableList").done(function(data) {
- d_self.items.removeAll(); //need to remove again before callback executes
- for(q=0; q<data.length; q++) {
- d_self.items.push(new TableDataRow(data[q]));
- }
- d_self._el.find('a[data-row-selector=true]').jHueRowSelector();
- if(callback!=null)
- callback();
- });
- }}),
- tabledata: new SmartViewModel({'canWrite': canWrite, el: 'views.tabledata', reload: function(callback) //move inside SmartViewModel class?
- {
- var t_self = this;
- function getColumnFamilies() {
- var cols = [];
- var cfs = t_self.columnFamilies();
- for(var i=0; i<cfs.length; i++) {
- if(cfs[i].enabled()) {
- cols.push(cfs[i].name);
- }
- }
- return cols;
- }
- API.queryTable("getRowQuerySet", JSON.stringify(getColumnFamilies()), ko.toJSON(t_self.querySet())).done(function(data) {
- if(data.length > 0) {
- var keys = Object.keys(data);
- var items = [];
- for(var i=0; i<keys.length; i++) {
- var row = new SmartViewDataRow({'canWrite': canWrite, items: [], row:data[keys[i]].row, reload: function(options) {
- var self = this;
- options = (options == null) ? {} : options;
- options = ko.utils.extend({
- callback: function(data){},
- columns: getColumnFamilies()
- }, options);
- API.queryTable("getRow", JSON.stringify(options.columns), prepForTransport(self.row)).done(function(data) {
- self.setItems(data.columns);
- callback(data);
- self.isLoading(false);
- });
- }});
- row.setItems(data[keys[i]].columns);
- items.push(row);
- }
- t_self.items(items);
- }
- if(typeof(callback) === 'function')
- callback();
- $('*[data-toggle="tooltip"]').tooltip();
- });
- }})
- };
- self.initialize = function() {
- return API.query('getClusters').done(function(data) {
- app.clusters(data);
- });
- };
- };
- var app = new AppViewModel();
- ko.applyBindings(app);
- //routing
- routed = false;
- app.initialize().done(function() {
- routie({
- ':cluster/:table/query': function(cluster, table) {
- routie(cluster + '/' + table);
- },
- ':cluster/:table/query/:query': function(cluster, table, query) {
- logGA('query_table');
- $.totalStorage('hbase_cluster', cluster);
- app.station('table');
- app.search.cur_input(query);
- Router.setTable(cluster, table);
- resetElements();
- Views.render('dataview');
- app.views.tabledata._reloadcfs(function(){
- app.search.evaluate();
- app.views.tabledata.searchQuery(query);
- });
- routed = true;
- },
- ':cluster/:table': function(cluster, table) {
- logGA('view_table');
- $.totalStorage('hbase_cluster', cluster);
- Router.setTable(cluster, table);
- resetSearch();
- resetElements();
- app.station('table');
- Views.render('dataview');
- routed = true;
- },
- ':cluster': function(cluster) {
- if ($.inArray(cluster, app.clusterNames()) == -1) {
- routie('');
- } else {
- logGA('view_cluster');
- $.totalStorage('hbase_cluster', cluster);
- app.station('cluster');
- app.cluster(cluster);
- app.pageTitle(cluster);
- Views.render('clusterview');
- resetSearch();
- resetElements();
- app.views.tabledata.name('');
- app.views.tables.reload();
- routed = true;
- }
- resetElements();
- routed = true;
- },
- 'error': function() {
- logGA('error');
- routed = true;
- },
- '': function(){
- var cluster = $.totalStorage('hbase_cluster');
- if (cluster != null && $.inArray(cluster, app.clusterNames()) > -1) {
- routie(cluster);
- } else {
- routie(app.clusterNames()[0]);
- }
- resetElements();
- routed = true;
- },
- '*': function() {
- logGA('');
- if(!routed)
- history.back();
- routed = false;
- }
- });
- });
- $.fn.renderElement = function(data){utils.renderElement($(this,data))};
- $.fn.showIndicator = function() {
- $(this).addClass('isLoading');
- }
- $.fn.hideIndicator = function() {
- $(this).removeClass('isLoading');
- }
- $.fn.toggleIndicator = function() {
- $(this).toggleClass('isLoading');
- }
- function bindSubmit() {
- var self = this;
- var data = [];
- var hash_cache = {};
- if ($(this).attr("id") == "new_table_modal"){
- var _cols = [];
- $(this).find(".columns li.column").each(function(cnt, column){
- var _props = {
- name: $(column).find("input[name='table_columns']").val()
- };
- $(column).find(".columnProperties li").each(function(icnt, property){
- if (! $(property).hasClass("columnPropertyEmpty")) {
- _props[$(property).find("select").val()] = $(property).find("input[name='table_columns_property_value']").val();
- }
- });
- _cols.push({
- properties: _props
- });
- });
- data = [
- $(this).find("input[name='cluster']").val(),
- $(this).find("input[name='tableName']").val(),
- JSON.stringify(_cols)
- ]
- }
- else {
- $(this).find('.controls > input, .controls > textarea, .controls > ul input').not('input[type=submit]').each(function() {
- if($(this).hasClass('ignore'))
- return;
- var use_post = $(this).data('use-post');
- var submitVal = null;
- if($(this).data('subscribe')) {
- var target = $($(this).data('subscribe'));
- switch(target[0].tagName) {
- case "UL":
- var serialized = {};
- target.find('li').each(function() {
- serialized[$(this).find('input')[0].value] = $(this).find('input')[1].value;
- });
- submitVal = serialized;
- use_post = true;
- break;
- }
- }
- else if($(this).hasClass('serializeHash')) {
- var target = $(this).attr('name');
- if(!hash_cache[target])
- hash_cache[target] = {};
- hash_cache[target][$(this).data(key)] = $(this).val();
- }
- else {
- submitVal = $(this).val();
- //change reload next
- }
- if(submitVal) {
- if(use_post) {
- submitVal = "hbase-post-key-" + JSON.stringify(submitVal);
- } else {
- submitVal = prepForTransport(submitVal);
- }
- data.push(submitVal);
- }
- });
- }
- $(this).find('input[type=submit]').addClass('disabled').showIndicator();
- var ui = app.focusModel();
- if(ui)
- ui.isLoading(true);
- API.queryArray($(this).attr('action'), data).complete(function() {
- $(self).find('input[type=submit]').removeClass('disabled').hideIndicator();
- if(ui)
- ui.isLoading(false);
- }).success(function() {
- $(self).modal('hide');
- if(ui)
- app.focusModel().reload();
- });
- return false;
- }
- $('form.ajaxSubmit').submit(bindSubmit).on('hidden', function() {
- $(this).trigger('reset');
- });
- var prepareNewTableForm = function () {
- $("#new_table_modal .modal-body ul").empty();
- addColumnToNewTableForm();
- }
- var addColumnToNewTableForm = function() {
- var $li = $("<li>").addClass("column").css("marginBottom", "10px").html($("#columnTemplate").html());
- $li.find("ul").html($("#columnPropertyEmptyTemplate").html());
- $li.appendTo($("#new_table_modal .modal-body ul.columns"));
- }
- var addColumnPropertyToColumn = function (col){
- var $li = $("<li>").addClass("columnProperty").css("marginBottom", "5px").html($("#columnPropertyTemplate").html());
- $li.find("select").on("change", function(){
- $li.find("[name='table_columns_property_value']").attr("placeholder", $(this).find("option:selected").data("default"));
- });
- $li.appendTo(col.find("ul"));
- }
- $(document).on("click", "a.action_addColumn", function() {
- addColumnToNewTableForm();
- });
- $(document).on("click", "a.action_removeColumn", function() {
- $(this).parents("li").remove();
- });
- $(document).on("click", "a.action_addColumnProperty", function() {
- addColumnPropertyToColumn($(this).parents(".column"));
- $(this).parents(".column").find(".columnPropertyEmpty").remove();
- });
- $(document).on("click", "a.action_removeColumnProperty", function() {
- var _col = $(this).parents(".column");
- _col.find(".columnPropertyEmpty").remove();
- $(this).parent().remove();
- if (_col.find("li").length == 0){
- _col.find("ul").html($("#columnPropertyEmptyTemplate").html());
- }
- });
|