chenhao7253886 commented on a change in pull request #1003: Support kafka
routine load
URL: https://github.com/apache/incubator-doris/pull/1003#discussion_r277925236
##########
File path:
fe/src/main/java/org/apache/doris/analysis/CreateRoutineLoadStmt.java
##########
@@ -153,122 +178,129 @@ public int getDesiredConcurrentNum() {
return desiredConcurrentNum;
}
- public int getMaxErrorNum() {
+ public long getMaxErrorNum() {
return maxErrorNum;
}
- public String getKafkaEndpoint() {
- return kafkaEndpoint;
+ public long getMaxBatchIntervalS() {
+ return maxBatchIntervalS;
+ }
+
+ public long getMaxBatchRows() {
+ return maxBatchRows;
+ }
+
+ public long getMaxBatchSize() {
+ return maxBatchSizeBytes;
+ }
+
+ public String getKafkaBrokerList() {
+ return kafkaBrokerList;
}
public String getKafkaTopic() {
return kafkaTopic;
}
- public List<Integer> getKafkaPartitions() {
- return kafkaPartitions;
+ public List<Pair<Integer, Long>> getKafkaPartitionOffsets() {
+ return kafkaPartitionOffsets;
}
@Override
- public void analyze(Analyzer analyzer) throws AnalysisException,
UserException {
+ public void analyze(Analyzer analyzer) throws UserException {
super.analyze(analyzer);
+ // check dbName and tableName
+ checkDBTable(analyzer);
// check name
Review comment:
The checkDBTable throws AnalysisException, but analyze does't catch it or
throws it too.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to 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]
