hi all,

The following message from Warden, we can discuss interaction between core
and dispatcher module here.
====================
I have drafted the communication messages between core and dispatcher as
below,


// submit sql
execute(RecordRequest) return RecordResponse;

RecordRequest {
 String recordSql;
 Enum engine;  // Spark,Hive,Presto,etc.
 String owner;
 Integer maxRetryCount;
}

RecordResponse {
 Integer code;
 Long value;
 Enum errorCode; // if code != 200, please tell us what happened:
     //    1、 recordSql syntax error
     //    2、 internal error, dispatcher self is crashed
     //    3、 external error, target engine is crashed when dispatcher
call,etc
 Exception ex;   // error detail info
}

// validate sql syntax
validateSQL(CheckRequest) return CheckResponse;

ValidateSQLRequest {
 String recordSql;
 Enum engine;  // Spark,Hive,Presto,etc.
}

ValidateSQLResponse {
 Integer code;
 Enum errorCode; // if code != 200, please tell us what happened:
     //    1、 recordSql syntax error
     //    2、 internal error, dispatcher self is crashed
     //    3、 external error, target engine is crashed when dispatcher
call,etc
 Exception ex;   // error detail info
}



Could you please review it? Give us your feedback.

==================

Reply via email to