You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ka...@apache.org on 2022/06/27 03:40:29 UTC
[rocketmq-streams] branch main updated: Corrects a spelling error in the word stream
This is an automated email from the ASF dual-hosted git repository.
karp pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
The following commit(s) were added to refs/heads/main by this push:
new 3f4c15eb Corrects a spelling error in the word stream
new bb7931f3 Merge pull request #176 from tongfs/main
3f4c15eb is described below
commit 3f4c15eb9b4f99d7af54ad083bf3230f75cc39e0
Author: tongfs <re...@outlook.com>
AuthorDate: Fri Jun 24 14:58:02 2022 +0800
Corrects a spelling error in the word stream
---
.../org/apache/rocketmq/streams/client/transform/JoinStream.java | 2 +-
.../rocketmq/streams/client/transform/OverWindowStream.java | 2 +-
.../apache/rocketmq/streams/client/transform/WindowStream.java | 2 +-
.../java/org/apache/rocketmq/streams/client/DataStreamTest.java | 2 +-
.../test/java/org/apache/rocketmq/streams/client/JoinTest.java | 4 ++--
.../org/apache/rocketmq/streams/client/RocketMQGroupByTest.java | 2 +-
.../test/java/org/apache/rocketmq/streams/client/SplitTest.java | 4 ++--
.../test/java/org/apache/rocketmq/streams/client/UnionTest.java | 2 +-
.../test/java/org/apache/rocketmq/streams/client/WindowTest.java | 6 +++---
.../apache/rocketmq/streams/client/example/CountFromFileTest.java | 4 ++--
.../rocketmq/streams/client/example/CountSupportEmitTest.java | 4 ++--
.../java/org/apache/rocketmq/streams/client/example/DimTest.java | 4 ++--
.../java/org/apache/rocketmq/streams/client/example/JoinTest.java | 6 +++---
.../apache/rocketmq/streams/client/source/MqttStreamsTest.java | 2 +-
.../streams/client/windows/AbstractWindowFireModeTest.java | 8 ++++----
.../rocketmq/streams/client/windows/AbstractWindowTest.java | 4 ++--
.../rocketmq/streams/client/windows/ShuffleOverWindowTest.java | 2 +-
.../rocketmq/streams/examples/aggregate/PageDimensionExample.java | 4 ++--
.../streams/examples/aggregate/RocketMQWindowExample.java | 2 +-
.../streams/examples/aggregate/UsersDimensionExample.java | 2 +-
.../streams/examples/checkpoint/RemoteCheckpointExample.java | 2 +-
.../rocketmq/streams/examples/join/RocketmqDimJoinExample.java | 2 +-
.../rocketmq/streams/examples/join/RocketmqJoinExample.java | 2 +-
.../streams/examples/mutilconsumer/MultiStreamsExample.java | 2 +-
.../rocketmq/streams/examples/source/MqttSourceExample.java | 2 +-
.../rocketmq/streams/examples/source/RocketmqSourceExample4.java | 2 +-
26 files changed, 40 insertions(+), 40 deletions(-)
diff --git a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/JoinStream.java b/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/JoinStream.java
index 22c1f2a4..69f3960b 100644
--- a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/JoinStream.java
+++ b/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/JoinStream.java
@@ -160,7 +160,7 @@ public class JoinStream {
return this;
}
- public DataStream toDataSteam() {
+ public DataStream toDataStream() {
if (isDimJoin) {
return doDimJoin();
} else {
diff --git a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/OverWindowStream.java b/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/OverWindowStream.java
index 1c517fde..d95950a1 100644
--- a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/OverWindowStream.java
+++ b/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/OverWindowStream.java
@@ -74,7 +74,7 @@ public class OverWindowStream {
return this;
}
- public DataStream toDataSteam() {
+ public DataStream toDataStream() {
return new DataStream(pipelineBuilder, otherPipelineBuilders, currentChainStage);
}
diff --git a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java b/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java
index 1ff3564e..37abdf51 100644
--- a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java
+++ b/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java
@@ -258,7 +258,7 @@ public class WindowStream {
return new DataStream(pipelineBuilder, otherPipelineBuilders, currentChainStage);
}
- public DataStream toDataSteam() {
+ public DataStream toDataStream() {
return new DataStream(pipelineBuilder, otherPipelineBuilders, currentChainStage);
}
}
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/DataStreamTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/DataStreamTest.java
index 2484af5e..21e64073 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/DataStreamTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/DataStreamTest.java
@@ -98,7 +98,7 @@ public class DataStreamTest implements Serializable {
.groupBy("name", "age")
.count("c")
.sum("score", "scoreValue")
- .toDataSteam()
+ .toDataStream()
.toPrint(1)
.with(WindowStrategy.exactlyOnce("", "", ""))
.start();
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/JoinTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/JoinTest.java
index a4ff64b2..1b15d712 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/JoinTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/JoinTest.java
@@ -56,7 +56,7 @@ public class JoinTest implements Serializable {
leftStream.join(rightStream).setJoinType(JoinType.INNER_JOIN)
.setCondition("(ProjectName,==,ProjectName)&(LogStore,==,LogStore)")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.start();
@@ -74,7 +74,7 @@ public class JoinTest implements Serializable {
}))
.join("dburl", "dbUserName", "dbPassowrd", "tableNameOrSQL", 5)
.setCondition("(name,==,name)")
- .toDataSteam()
+ .toDataStream()
.selectFields("name", "age", "address")
.toPrint();
stream.start();
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/RocketMQGroupByTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/RocketMQGroupByTest.java
index f5e1ab77..014316b6 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/RocketMQGroupByTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/RocketMQGroupByTest.java
@@ -35,7 +35,7 @@ public class RocketMQGroupByTest implements Serializable {
.window(TumblingWindow.of(Time.seconds(5)))
.groupBy("host_uuid", "cmdline")
.count("c")
- .toDataSteam()
+ .toDataStream()
.forEachMessage(new ForEachMessageFunction() {
protected AtomicLong COUNT = new AtomicLong(0);
protected Long start = null;
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/SplitTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/SplitTest.java
index ff5e860a..949fb6ab 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/SplitTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/SplitTest.java
@@ -61,7 +61,7 @@ public class SplitTest implements Serializable {
DataStream children = splitStream.select("children");
DataStream adult = splitStream.select("adult");
- children.union(adult).join("dburl", "dbUserName", "dbPassowrd", "tableNameOrSQL", 5).setCondition("(name,==,name)").toDataSteam().window(TumblingWindow.of(Time.seconds(5))).groupBy("ProjectName", "LogStore").setLocalStorageOnly(true).count("total").sum("OutFlow", "OutFlow").sum("InFlow", "InFlow").toDataSteam().toPrint().asyncStart();
+ children.union(adult).join("dburl", "dbUserName", "dbPassowrd", "tableNameOrSQL", 5).setCondition("(name,==,name)").toDataStream().window(TumblingWindow.of(Time.seconds(5))).groupBy("ProjectName", "LogStore").setLocalStorageOnly(true).count("total").sum("OutFlow", "OutFlow").sum("InFlow", "InFlow").toDataStream().toPrint().asyncStart();
while (true) {
Thread.sleep(1000);
}
@@ -79,7 +79,7 @@ public class SplitTest implements Serializable {
}
return false;
}
- })).join("dburl", "dbUserName", "dbPassowrd", "tableNameOrSQL", 5).setCondition("(name,==,name)").toDataSteam().selectFields("name", "age", "address").toPrint();
+ })).join("dburl", "dbUserName", "dbPassowrd", "tableNameOrSQL", 5).setCondition("(name,==,name)").toDataStream().selectFields("name", "age", "address").toPrint();
stream.start();
}
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/UnionTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/UnionTest.java
index 2bef585d..11066257 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/UnionTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/UnionTest.java
@@ -72,7 +72,7 @@ public class UnionTest implements Serializable {
}))
.join("dburl", "dbUserName", "dbPassowrd", "tableNameOrSQL", 5)
.setCondition("(name,==,name)")
- .toDataSteam()
+ .toDataStream()
.selectFields("name", "age", "address")
.toPrint();
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/WindowTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/WindowTest.java
index 3be7c46c..89dd21b5 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/WindowTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/WindowTest.java
@@ -48,7 +48,7 @@ public class WindowTest implements Serializable {
.count("total")
.sum("OutFlow", "OutFlow")
.sum("InFlow", "InFlow")
- .toDataSteam()
+ .toDataStream()
.forEach(new ForEachFunction<JSONObject>() {
protected int sum = 0;
@@ -153,7 +153,7 @@ public class WindowTest implements Serializable {
.groupBy("user")
.setLocalStorageOnly(true)
.sum("flag", "count")
- .toDataSteam()
+ .toDataStream()
.toFile(resultFile.getAbsolutePath()).start(true);
try {
@@ -253,7 +253,7 @@ public class WindowTest implements Serializable {
.count_distinct("page", "uv")
.count_distinct_large("page", "uv_large")
.count_distinct_2("page", "uv_2")
- .toDataSteam()
+ .toDataStream()
.toFile(resultFile.getAbsolutePath()).start(true);
try {
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/CountFromFileTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/CountFromFileTest.java
index 606de357..5d25946c 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/CountFromFileTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/CountFromFileTest.java
@@ -33,7 +33,7 @@ public class CountFromFileTest {
.fromFile("window_msg_88121.txt", true)
.window(TumblingWindow.of(Time.seconds(5)))
.count("count_result")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.start();
}
@@ -46,7 +46,7 @@ public class CountFromFileTest {
.fromFile("window_msg_10000.txt", true)
.window(HoppingWindow.of(Time.seconds(10), Time.seconds(5)))
.count("count_result")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.start();
}
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/CountSupportEmitTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/CountSupportEmitTest.java
index 26bc9c15..28250680 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/CountSupportEmitTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/CountSupportEmitTest.java
@@ -34,7 +34,7 @@ public class CountSupportEmitTest {
.window(TumblingWindow.of(Time.minutes(10)))
.emitBeforeFire(Time.seconds(5))
.count("count_result")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.start();
;
@@ -48,7 +48,7 @@ public class CountSupportEmitTest {
.fromFile("window_msg_10000.txt", true)
.window(HoppingWindow.of(Time.seconds(10), Time.seconds(5)))
.count("count_result")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.start();
;
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/DimTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/DimTest.java
index 1004925c..abc50033 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/DimTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/DimTest.java
@@ -29,7 +29,7 @@ public class DimTest {
.join("classpath://dim.txt", 10000)
.setJoinType(JoinStream.JoinType.INNER_JOIN)
.setCondition("(ProjectName,=,project)")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.start();
}
@@ -41,7 +41,7 @@ public class DimTest {
.join("classpath://dim.txt", 10000)
.setJoinType(JoinStream.JoinType.LEFT_JOIN)
.setCondition("(ProjectName,=,project)")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.start();
}
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/JoinTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/JoinTest.java
index d3a5f7aa..53bbee43 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/JoinTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/example/JoinTest.java
@@ -64,7 +64,7 @@ public class JoinTest {
DataStream right = StreamBuilder.dataStream("tmp", "tmp2").fromFile("dim.txt", true);
- left.join(right).on("(ProjectName,=,project)").toDataSteam().toPrint().start();
+ left.join(right).on("(ProjectName,=,project)").toDataStream().toPrint().start();
}
@@ -74,7 +74,7 @@ public class JoinTest {
DataStream right = StreamBuilder.dataStream("tmp", "tmp2").fromFile("dim.txt", true);
- left.leftJoin(right).on("(ProjectName,=,project)").toDataSteam().toPrint().start();
+ left.leftJoin(right).on("(ProjectName,=,project)").toDataStream().toPrint().start();
}
@Test
@@ -84,7 +84,7 @@ public class JoinTest {
//DataStream right = StreamBuilder.dataStream("tmp", "tmp2").fromFile("dim.txt", true);
DataStream right = StreamBuilder.dataStream("tmp", "tmp").fromRocketmq("TopicTest", "groupB", true, "localhost:9876");
- left.join(right).on("(ProjectName,=,project)").toDataSteam().toPrint().start();
+ left.join(right).on("(ProjectName,=,project)").toDataStream().toPrint().start();
}
}
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/source/MqttStreamsTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/source/MqttStreamsTest.java
index 9f272304..48162677 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/source/MqttStreamsTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/source/MqttStreamsTest.java
@@ -40,7 +40,7 @@ public class MqttStreamsTest {
.groupBy("AttributeCode")
.setLocalStorageOnly(true)
.avg("Value", "avg_value")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.with(ShuffleStrategy.shuffleWithMemory())
.start();
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowFireModeTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowFireModeTest.java
index 39c04ee8..70ac93c9 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowFireModeTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowFireModeTest.java
@@ -76,7 +76,7 @@ public abstract class AbstractWindowFireModeTest implements Serializable {
.count("total")
.sum("OutFlow", "OutFlow")
.sum("InFlow", "inflow")
- .toDataSteam()
+ .toDataStream()
.forEach(new ForEachFunction<JSONObject>() {
AtomicInteger sum = new AtomicInteger(0) ;
@Override
@@ -120,7 +120,7 @@ public abstract class AbstractWindowFireModeTest implements Serializable {
.count("total")
.sum("OutFlow", "OutFlow")
.sum("InFlow", "InFlow")
- .toDataSteam()
+ .toDataStream()
.forEach(new ForEachFunction<JSONObject>() {
@@ -161,7 +161,7 @@ public abstract class AbstractWindowFireModeTest implements Serializable {
.count("total")
.sum("OutFlow", "OutFlow")
.sum("InFlow", "InFlow")
- .toDataSteam()
+ .toDataStream()
.map(new MapFunction<JSONObject, JSONObject>() {
long time=new Date().getTime();
@Override
@@ -178,7 +178,7 @@ public abstract class AbstractWindowFireModeTest implements Serializable {
.setTimeField("time")
.sum("total","sum_total")
.setLocalStorageOnly(true)
- .toDataSteam()
+ .toDataStream()
.forEach(new ForEachFunction<JSONObject>() {
AtomicInteger sum = new AtomicInteger(0) ;
Map<String,Integer> map=new HashMap<>();
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowTest.java
index 5a5c346b..75769f0b 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/AbstractWindowTest.java
@@ -75,7 +75,7 @@ public abstract class AbstractWindowTest implements Serializable {
.setTimeField("time")
.sum("total", "sum_total")
.setLocalStorageOnly(isLocalOnly)
- .toDataSteam()
+ .toDataStream()
.forEach(new ForEachFunction<JSONObject>() {
AtomicInteger sum = new AtomicInteger(0);
Map<String, Integer> map = new HashMap<>();
@@ -144,7 +144,7 @@ public abstract class AbstractWindowTest implements Serializable {
.count("total")
.sum("OutFlow", "OutFlow")
.sum("InFlow", "inflow")
- .toDataSteam()
+ .toDataStream()
.forEach(new ForEachFunction<JSONObject>() {
AtomicInteger sum = new AtomicInteger(0);
diff --git a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/ShuffleOverWindowTest.java b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/ShuffleOverWindowTest.java
index 8794a909..acdeedb1 100644
--- a/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/ShuffleOverWindowTest.java
+++ b/rocketmq-streams-clients/src/test/java/org/apache/rocketmq/streams/client/windows/ShuffleOverWindowTest.java
@@ -33,7 +33,7 @@ public class ShuffleOverWindowTest {
.topN("rowNum", 10000, "city")
.addOrderByFieldName("name", true)
.addOrderByFieldName("age", false)
- .toDataSteam()
+ .toDataStream()
.toPrint()
.start();
}
diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/PageDimensionExample.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/PageDimensionExample.java
index 55ed468a..3685ff1c 100644
--- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/PageDimensionExample.java
+++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/PageDimensionExample.java
@@ -54,7 +54,7 @@ public class PageDimensionExample {
.count("total")
.waterMark(1)
.setLocalStorageOnly(true)
- .toDataSteam()
+ .toDataStream()
.toFile("/home/result.txt")
.with(WindowStrategy.highPerformance())
.start();
@@ -71,7 +71,7 @@ public class PageDimensionExample {
.max("total")
.waterMark(1)
.setLocalStorageOnly(true)
- .toDataSteam()
+ .toDataStream()
.toPrint(1)
.start();
diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/RocketMQWindowExample.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/RocketMQWindowExample.java
index 5461f8dd..82d51d90 100644
--- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/RocketMQWindowExample.java
+++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/RocketMQWindowExample.java
@@ -70,7 +70,7 @@ public class RocketMQWindowExample {
.count("total")
.waterMark(5)
.setLocalStorageOnly(true)
- .toDataSteam()
+ .toDataStream()
.toPrint(1)
.with(WindowStrategy.highPerformance())
.start();
diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/UsersDimensionExample.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/UsersDimensionExample.java
index a6c163df..2a4abdf4 100644
--- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/UsersDimensionExample.java
+++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/aggregate/UsersDimensionExample.java
@@ -53,7 +53,7 @@ public class UsersDimensionExample {
.count("total")
.waterMark(1)
.setLocalStorageOnly(true)
- .toDataSteam()
+ .toDataStream()
.toPrint(1)
.with(WindowStrategy.highPerformance())
.start();
diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/checkpoint/RemoteCheckpointExample.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/checkpoint/RemoteCheckpointExample.java
index 1016e689..62d760dd 100644
--- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/checkpoint/RemoteCheckpointExample.java
+++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/checkpoint/RemoteCheckpointExample.java
@@ -89,7 +89,7 @@ public class RemoteCheckpointExample {
.count("total")
.waterMark(5)
.setLocalStorageOnly(false)
- .toDataSteam()
+ .toDataStream()
.toPrint(1)
.start();
}
diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqDimJoinExample.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqDimJoinExample.java
index 7246f6f7..8bc87de3 100644
--- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqDimJoinExample.java
+++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqDimJoinExample.java
@@ -25,7 +25,7 @@ public class RocketmqDimJoinExample {
.fromRocketmq("TopicTest", "groupA", true, "localhost:9876")
.dimJoin("classpath://dim.txt", 10000L)
.on("ProjectName, =, project")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.start();
}
diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java
index f4270d8a..8a149ac0 100644
--- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java
+++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/join/RocketmqJoinExample.java
@@ -28,7 +28,7 @@ public class RocketmqJoinExample {
left.join(right)
.on("(ProjectName,=,ProjectName)")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.start();
}
diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/mutilconsumer/MultiStreamsExample.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/mutilconsumer/MultiStreamsExample.java
index 44b22dbe..888fc69b 100644
--- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/mutilconsumer/MultiStreamsExample.java
+++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/mutilconsumer/MultiStreamsExample.java
@@ -85,7 +85,7 @@ public class MultiStreamsExample {
.count("total")
.waterMark(5)
.setLocalStorageOnly(true)
- .toDataSteam()
+ .toDataStream()
.toPrint(1)
.with(WindowStrategy.highPerformance())
.start();
diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/MqttSourceExample.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/MqttSourceExample.java
index d0dbad59..33b8b0a4 100644
--- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/MqttSourceExample.java
+++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/MqttSourceExample.java
@@ -33,7 +33,7 @@ public class MqttSourceExample {
.groupBy("AttributeCode")
.setLocalStorageOnly(true)
.avg("Value", "avg_value")
- .toDataSteam()
+ .toDataStream()
.toPrint()
.with(ShuffleStrategy.shuffleWithMemory())
.start();
diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/RocketmqSourceExample4.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/RocketmqSourceExample4.java
index c9f15839..d117fb1c 100644
--- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/RocketmqSourceExample4.java
+++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/RocketmqSourceExample4.java
@@ -55,7 +55,7 @@ public class RocketmqSourceExample4 {
return false;
});
- leftStream.leftJoin(rightStream).setCondition("(ProjectName,==,ProjectName)&(LogStore,==,LogStore)").toDataSteam().toPrint(1).start();
+ leftStream.leftJoin(rightStream).setCondition("(ProjectName,==,ProjectName)&(LogStore,==,LogStore)").toDataStream().toPrint(1).start();
System.out.println("consumer end");
}