EmmyMiao87 opened a new pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456 1. Add sql parser and sql scanner for routine load stmt such as KW_ROUTINE_LOAD(routine load), KW_PAUSE. 2. Create routine load statment like CREATE ROUTINE LOAD name ON database.table (properties of routine load) [PROPERTIES (key1=value1, )] FROM [KAFKA](type of routine load) (properties of this type) properties of routine load: [COLUMNS TERMINATED BY separator ] [(col1, ...)] [SET (k1=f1(xx), k2=f2(xx))] WHERE [PARTITION (p1, p2)] type of routine load: KAFKA different type has different properties properties of this type: k1 = v1 k2 = v2 3. Pause/Resume/Stop routine load statment like PAUSE/RESUME/STOP ROUTINE LOAD jobId 4. Ddlexecutor support CreateRoutineLoadStmt, Pause/Resume/StopRoutineLoadStmt 5. Pause/Stop routine load will clear all of task which belong to job immediately The task which has been not committed will be abort. 6. Resume routine load will change job state to need scheduler The RoutineLoadJobScheduler will scheduler it later.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
