[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r244935287 ## File path: fe/src/main/java/org/apache/doris/load/routineload/StreamDataSourceType.java ## @@ -0,0 +1,23 @@ +// Lic

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r244903984 ## File path: fe/src/main/java/org/apache/doris/load/routineload/RoutineLoadManager.java ## @@ -132,8 +149,140 @@ publi

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r244901614 ## File path: fe/src/main/java/org/apache/doris/analysis/CreateRoutineLoadStmt.java ## @@ -0,0 +1,323 @@ +// Licensed t

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r244901604 ## File path: fe/src/main/java/org/apache/doris/analysis/CreateRoutineLoadStmt.java ## @@ -0,0 +1,323 @@ +// Licensed t

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r244903661 ## File path: fe/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java ## @@ -55,155 +69,224 @@ * The r

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r244901815 ## File path: fe/src/main/java/org/apache/doris/analysis/CreateRoutineLoadStmt.java ## @@ -0,0 +1,323 @@ +// Licensed t

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r244901751 ## File path: fe/src/main/java/org/apache/doris/analysis/CreateRoutineLoadStmt.java ## @@ -0,0 +1,323 @@ +// Licensed t

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r244299480 ## File path: fe/src/main/java/org/apache/doris/analysis/CreateRoutineLoadStmt.java ## @@ -0,0 +1,336 @@ +// Licensed t

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r244900197 ## File path: fe/src/main/cup/sql_parser.cup ## @@ -1103,6 +1146,87 @@ opt_cluster ::= :} ; +// Routine load

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r243995696 ## File path: fe/src/main/java/org/apache/doris/load/routineload/KafkaRoutineLoadJob.java ## @@ -55,16 +58,26 @@ /

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r243994453 ## File path: fe/src/main/java/org/apache/doris/analysis/CreateRoutineLoadStmt.java ## @@ -0,0 +1,337 @@ +// Licensed t

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r243994582 ## File path: fe/src/main/java/org/apache/doris/analysis/CreateRoutineLoadStmt.java ## @@ -0,0 +1,337 @@ +// Licensed t

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r243909920 ## File path: fe/src/main/cup/sql_parser.cup ## @@ -1103,6 +1146,87 @@ opt_cluster ::= :} ; +// Routine load

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r243910295 ## File path: fe/src/main/java/org/apache/doris/analysis/LoadProperty.java ## @@ -0,0 +1,25 @@ +// Licensed to the Apach

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r243603710 ## File path: fe/src/main/cup/sql_parser.cup ## @@ -1103,6 +1122,63 @@ opt_cluster ::= :} ; +// Routine load

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r243602240 ## File path: fe/src/main/cup/sql_parser.cup ## @@ -1103,6 +1122,63 @@ opt_cluster ::= :} ; +// Routine load

[GitHub] imay commented on a change in pull request #456: Add routine load statement

imay commented on a change in pull request #456: Add routine load statement URL: https://github.com/apache/incubator-doris/pull/456#discussion_r243602333 ## File path: fe/src/main/cup/sql_parser.cup ## @@ -205,7 +206,9 @@ terminal String KW_ADD, KW_ADMIN, KW_AFTER, KW_AGGRE