This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git.
from a52104f [Bug] Fix bug that DROP SCHEMA will forcibly database (#6729)
add f49362b [Demo] Add Spark-Doris-Sink demo (#6570)
No new revisions were added by this update.
Summary of changes:
samples/doris-demo/spark-demo/pom.xml | 21 +++++++
.../demo/spark/constant/SparkToDorisConstants.java | 21 ++++---
.../demo/connector/SparkDorisConnectorDemo.java | 53 ++++++++++++++++
.../demo/hdfs/MyForeachPartitionFunction.java | 71 ++++++++++++++++++++++
.../demo/spark/demo/hdfs/SparkHdfsToDorisDemo.java | 46 ++++++++++++++
.../spark/demo/kafka/SparkKafkaToDorisDemo.java | 68 +++++++++++++++++++++
.../apache/doris/demo/spark/sink/DorisSink.java | 61 +++++++++++++++++++
.../doris/demo/spark/util}/DorisStreamLoad.java | 35 ++++-------
.../org/apache/doris/demo/spark/vo/TestVo.java | 20 ++++--
9 files changed, 361 insertions(+), 35 deletions(-)
copy be/src/exec/empty_set_node.cpp =>
samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/constant/SparkToDorisConstants.java
(56%)
create mode 100644
samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/connector/SparkDorisConnectorDemo.java
create mode 100644
samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/hdfs/MyForeachPartitionFunction.java
create mode 100644
samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/hdfs/SparkHdfsToDorisDemo.java
create mode 100644
samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/demo/kafka/SparkKafkaToDorisDemo.java
create mode 100644
samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/sink/DorisSink.java
copy samples/doris-demo/{flink-demo/src/main/java/org/apache/doris/demo/flink
=>
spark-demo/src/main/java/org/apache/doris/demo/spark/util}/DorisStreamLoad.java
(88%)
copy
extension/flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java
=>
samples/doris-demo/spark-demo/src/main/java/org/apache/doris/demo/spark/vo/TestVo.java
(73%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
