Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
0002934: Make the dashboard more useful. Allow different quadrants to be
configured.
  • Loading branch information
chenson42 committed Jul 3, 2017
1 parent a64a044 commit cd34255
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
Expand Up @@ -95,7 +95,8 @@ public IncomingBatchServiceSqlMap(IDatabasePlatform platform, Map<String, String
putSql("selectIncomingBatchSummaryByStatusAndChannelSql",
"select count(*) as batches, s.status, sum(s.load_row_count) as data, s.node_id, min(s.create_time) as oldest_batch_time, s.channel_id, "
+ " max(s.last_update_time) as last_update_time, b.sql_message as sql_message, min(s.batch_id) as batch_id "
+ " from $(incoming_batch) s join $(incoming_batch) b on b.batch_id=s.batch_id and b.node_id=s.node_id where s.status in (:STATUS_LIST) group by s.status, s.node_id, s.channel_id, b.sql_message order by oldest_batch_time asc ");
+ " from $(incoming_batch) s join $(incoming_batch) b on b.batch_id=s.batch_id and b.node_id=s.node_id "
+ " join $(node) n on n.node_id=b.node_id and n.sync_enabled=1 where s.status in (:STATUS_LIST) group by s.status, s.node_id, s.channel_id, b.sql_message order by oldest_batch_time asc ");

putSql("selectIncomingBatchSummaryByStatusSql",
"select count(*) as batches, status, sum(load_row_count) as data, node_id, min(create_time) as oldest_batch_time, "
Expand Down
Expand Up @@ -148,7 +148,8 @@ public OutgoingBatchServiceSqlMap(IDatabasePlatform platform,
+ " sum(s.router_millis) as total_router_millis, sum(s.extract_millis) as total_extract_millis, "
+ " sum(s.network_millis) as total_network_millis, sum(s.filter_millis) as total_filter_millis, "
+ " sum(s.load_millis) as total_load_millis "
+ " from $(outgoing_batch) s join $(outgoing_batch) b on b.batch_id=s.batch_id and b.node_id=s.node_id"
+ " from $(outgoing_batch) s join $(outgoing_batch) b on b.batch_id=s.batch_id and b.node_id=s.node_id join"
+ " $(node) n on n.node_id=s.node_id and n.sync_enabled=1"
+ " where s.status in (:STATUS_LIST) group by s.status, s.node_id, s.channel_id, b.sql_message order by s.node_id, oldest_batch_time asc ");

putSql("updateOutgoingBatchesStatusSql",
Expand Down

0 comments on commit cd34255

Please sign in to comment.