31:T552,viewof rawAndQ1Delta = { if (!compareRawAndQ1Delta) { return embed({}); } let processedData = d3.nest() .key(v => v['FINALMACHINENAME']) .entries(trs) .sort((a,b) => b.values.length - a.values.length) // // .filter(r => r.key.startsWith('DAA')) // .slice(0, 15) .map(r => r.values) .flat(); let result = embed({ data : { values : processedData }, encoding : { y : { field : 'STARTTIME', type : 'temporal' }, }, hconcat : [ { height : 1600, width : 200, mark : { type : 'point', opacity : 0.2, size : 3, color : vega.scheme('tableau10')[2] }, encoding : { x : { field : 'macroDT', type : 'quantitative' } , y : { field : 'STARTTIME', type : 'temporal' }, tooltip : [ { field : 'FINALMACHINENAME', type : 'nominal' } ] } }, { height : 1600, width : 200, mark : { type : 'point', opacity : 0.2, size : 3, color : vega.scheme('tableau10')[0] }, encoding : { x : { field : 'dtNormDelta', type : 'quantitative' } , y : { field : 'STARTTIME', type : 'temporal' }, tooltip : [ { field : 'FINALMACHINENAME', type : 'nominal' } ] } } ] }, { renderer : 'svg'} ); return result; }32:T484,viewof brushedTr = function(arg){ updateButton; let microTrInRange = trs.filter(r => r['STARTTIME'] >= arg[1][0] && r['STARTTIME'] < arg[1][1]) .filter(r => r['dtNormDelta'] >= arg[0][0] && r['dtNormDelta'] < arg[0][1]) .sort( (a, b) => a['STARTTIME'].getTime() - b['STARTTIME'].getTime() ) .slice(0, 120) // max 120 macro commands .map(r => r.values).flat(); let result = embed( { data : { values : microTrInRange }, vconcat : [ { mark : { type : 'bar' }, encoding : { x : { field : 'microDtNormDelta', type : 'quantitative', aggregate : 'sum' }, color : { field : 'key', type : 'nominal' } , order : { aggregate : 'sum', field : 'microDtNormDelta', type : 'quantitative', order : 'descending' } } }, { mark : { type : 'bar' }, encoding: { y : { field : 'COMMANDID', type : 'nominal' }, x : { field : 'microDtNormDelta', type : 'quantitative', aggregate : 'sum' }, color : { field : 'key', type : 'nominal' }, } } ] }); debugger; return result; }(overview['brush']);33:T75a,trs = { // FIXME // return []; let rawData = await d3.tsv(trDataUrl2, r => { return _.omit(r, ['ID', 'PARTITIONID', 'ID_1', 'PARTITIONID_1']); }); let statisticsByKey = d3.nest().key(v => v['id']).object(statistics); let filteredData = rawData.filter( r => statisticsByKey[r['FROMMACHINENAME'] + '~' + r['TRANSMACHINENAME'] + '~' + r['TOMACHINENAME']] ); filteredData.forEach(r => { for(let key of ['SEQUENCE']) { r[key] = +r[key]; } for(let key of ['COMMANDTIME', 'STARTTIME', 'ENDTIME', 'STARTTIME_1', 'ENDTIME_1']){ r[key] = new Date(r[key]); } r['key'] = r['FROMMACHINENAME'] + '~' + r['TRANSMACHINENAME'] + '~' + r['TOMACHINENAME']; r['microDt'] = (r['ENDTIME'].getTime() - r['COMMANDTIME'].getTime()) / 1000; if (!(undefined === statisticsByKey[r['key']])) { let foundStatistics = statisticsByKey[r['key']][0]; r['microDtNormDelta'] = //Math.max(0, r['microDt'] - +foundStatistics['ttQ1'] //) ; r['normDt'] = r['microDt'] / +foundStatistics['ttQ1']; r['normDt'] = isNaN(r['normDt']) ? 1 : r['normDt']; } }); let result = d3.nest().key(v => v['COMMANDID']) .sortValues( (a, b) => a['SEQUENCE'] - b['SEQUENCE'] ) .entries(filteredData); result.forEach(r => { r['STARTTIME'] = r.values[0]['STARTTIME_1']; r['ENDTIME'] = r.values[0]['ENDTIME_1']; r['SOURCEMACHINENAME'] = r.values[0]['SOURCEMACHINENAME']; r['FINALMACHINENAME'] = r.values[0]['FINALMACHINENAME']; r['dtNormDelta'] = r.values.map(r => r['microDtNormDelta']) .reduce( (a,b) => +a + +b); r['macroDT'] = (r['ENDTIME'].getTime() - r['STARTTIME'].getTime()) / 1000; r.values = _.map(r.values, tr => _.omit(tr, ['STARTTIME_1', 'ENDTIME_1', 'SOURCEMACHINENAME', 'FINALMACHINENAME'])); }); return result; }34:[] 2f:{"title":"4L_test_tr","cells":[{"id":0,"value":"md `\n# 4L_test_tr\n`","pinned":false,"hidden":false,"mode":"ojs"},{"id":342,"value":"md `

\nselect nt_movehistoryunit.*, nt_movehistory.*\n  from nt_movehistoryunit\njoin nt_movehistory on nt_movehistoryunit.commandid = nt_movehistory.commandid\n  where commandtime between sysdate - 2 and sysdate -2 + 1/2\n  ;\n

`","pinned":false,"hidden":false,"mode":"ojs"},{"id":743,"value":"viewof compareRawAndQ1Delta = checkbox([\"compare raw and q1delta\"])","pinned":false,"hidden":false,"mode":"ojs"},{"id":748,"value":"$31","pinned":false,"hidden":false,"mode":"ojs"},{"id":445,"value":"viewof overview = {\n let processedData = d3.nest()\n .key(v => v['FINALMACHINENAME'])\n .entries(trs)\n .sort((a,b) => b.values.length - a.values.length) //\n// .filter(r => r.key.startsWith('DAA'))\n// .slice(0, 15)\n .map(r => r.values)\n .flat();\n \n let result = embed({\n data : { values : processedData },\n height : 1600,\n width : 600,\n background : '#ffffd9',\n mark : { type : 'point', opacity : 0.3, size : 3, color : '#9494ff' /*vega.scheme('tableau10')[0]*/ },\n selection : {\n brush : { type : 'interval' },\n }, \n encoding : { \n x : { field : 'dtNormDelta', type : 'quantitative' } ,\n// y : { field : 'STARTTIME', type : 'temporal' },\n y : { field : 'ENDTIME', type : 'temporal' }, \n tooltip : [ { field : 'FINALMACHINENAME', type : 'nominal' } ]\n } \n }, { renderer : 'svg'} );\n \n return result;\n}","pinned":false,"hidden":false,"mode":"ojs"},{"id":526,"value":"viewof updateButton = {\n const form = html`

Fetching data

Under the hood