You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/08/03 06:51:00 UTC

[rocketmq-streams] 32/35: Update README.md

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

commit 7981c2349689954fb3531dd5e33ec2088a6a3f31
Author: Heng Du <du...@apache.org>
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
+```