This is an automated email from the ASF dual-hosted git repository.
duhengforever 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 7981c23 Update README.md
7981c23 is described below
commit 7981c2349689954fb3531dd5e33ec2088a6a3f31
Author: Heng Du <[email protected]>
AuthorDate: Mon Aug 2 20:47:11 2021 +0800
Update README.md
---
README.md | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/README.md b/README.md
index 92a9b2f..019ea63 100644
--- a/README.md
+++ b/README.md
@@ -13,7 +13,7 @@ import
org.apache.rocketmq.streams.client.transform.DataStream;
DataStreamSource source=StreamBuilder.dataStream("namespace","pipeline");
source
- .fromFile("/Users/junjie.cheng/text.txt",false)
+ .fromFile("～/admin/data/text.txt",false)
.map(message->message)
.toPrint(1)
.start();
@@ -104,4 +104,4 @@ source
.toPrint(1)
.with(CheckpointStrategy.db("jdbc:mysql://XXXXX:3306/XXXXX","","",0L))
.start();
-```
\ No newline at end of file
+```
