dtm_worker_detail

2016-09-03 14:27:01   0  举报





仅支持查看

dtm_worker_detail是一个用于记录和管理数据挖掘工作详细信息的系统。它可以帮助用户跟踪和监控数据挖掘任务的进度，包括任务的状态、完成度、所使用的算法和技术等。此外，dtm_worker_detail还可以提供详细的报告和分析，帮助用户了解数据挖掘结果的质量和应用价值。通过使用dtm_worker_detail，用户可以更加高效地管理数据挖掘项目，提高数据处理和分析的效率。

作者其他创作

大纲/内容

read auth resultdirectly

if out of order

OUT

set IN/HUP

directly

clientp_map_multi_query

IN/HUP

if NOT AUTOCOMMIT

insert/push_backnode-vecto perserver query order within server

LOCAL_XA_STATE_STARTED

read query result

STATE_CONNECTED_SERVER

client cache_cmds

GLOBAL_XA_STATE_START

if COMMIT

BEFORE LAST QUERY

send handshake

STATE_SEND_QUERY

send result

OUT/HUP

client tranx state

1.SET NAMES2.USE DB

clear()

add READVIEW for SELECT

insert/push_backserver(redundant)to perserver query order across server

FOLLOWING SERVERS

1.SET NAMES2.USE DB3. XA START

handle DDL(todo)

STATE_SEND_AUTH_RESULT

epoll

GLOBAL_XA_STATE_COMMIT

[save_global_status]LSET xid_status:cur_xid 3 modify_time 4 affected_sids(curr servers) 0 global status

SQL_XA_START_NUM

STATE_READ_QUERY

original query

server A tranx state

read query

if XA START

STATE_READ_QUERY_RESULT

central redis

read auth

incrclient-query result cntserver-recv query num

getview_map[server]

STATE_READ_AUTH_RESULT

server Ap_vec_self_buf

STATE_CONNECTED_CLIENT

if all local started

if QUERYof MULTI QUERY

STATE_READ_HANDSHAKE

if START TRANSACTION

set OUT/HUP

cache set charset

if MULTI QUERY

send auth result

set b_c_xid/view_map[this server's sid] from pvi

clientp_vec_last_query_servers

client pvs

setview_map[this server's sid] from pvi

[load_consistent_view]GET cur_checkpointHGETALL innodb_gid:checkpoint_xidSETEX checkpoint_xid:cur_xid 5 load[del_occupy_list]DEL checkpoint_xid:cur_xid

listen sock

LOCAL_XA_STATE_COMMITTED

server A query

p_vec_last_query_servers[client-query result cnt]perserve query order

LOCAL_XA_STATE_STARTING

STATE_SEND_AUTH

send QUERY

if AUTOCOMMIT

check user/pwd

client sock

FIRST SERVER

send auth

read handshake

push_back send_buf

worker redis

STATE_READ_AUTH

LAST QUERY

[save_global_status]RPUSH xid_status:cur_xid 0(start) 0 b_c_xid modify_time affected_sids(first server)INCR ref_count:b_c_xidSADD ref_count_set:b_c_xid cur_xid

append all server's vec_self_buf to client-send_bufand then free()

load view_mapbase_checkpoint_xid from central redis

client query

client pvi

lock redis

server A sock

cache use db

STATE_SEND_HANDSHAKE

send XA START