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/21 03:55:10 UTC
[rocketmq-streams] 11/16: make FileSourceExample runnable
This is an automated email from the ASF dual-hosted git repository.
karp pushed a commit to branch snapshot-1.0.4
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
commit 4d94b411e56b98cc2fada8013a686ebe0bc59962
Author: 维章 <un...@gmail.com>
AuthorDate: Mon May 30 15:03:58 2022 +0800
make FileSourceExample runnable
---
.../apache/rocketmq/streams/examples/source/FileSourceExample.java | 2 +-
rocketmq-streams-examples/src/main/resources/joinData-2.txt | 4 ++++
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/FileSourceExample.java b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/FileSourceExample.java
index ecaf0bca..b51ea2eb 100644
--- a/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/FileSourceExample.java
+++ b/rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/FileSourceExample.java
@@ -22,7 +22,7 @@ import org.apache.rocketmq.streams.client.source.DataStreamSource;
public class FileSourceExample {
public static void main(String[] args) {
DataStreamSource source = StreamBuilder.dataStream("namespace", "pipeline");
- source.fromFile("/Users/junjie.cheng/jobs/access.log", false)
+ source.fromFile("data.txt", false)
.map(message -> message)
.toPrint(1)
.start();
diff --git a/rocketmq-streams-examples/src/main/resources/joinData-2.txt b/rocketmq-streams-examples/src/main/resources/joinData-2.txt
new file mode 100644
index 00000000..a711532a
--- /dev/null
+++ b/rocketmq-streams-examples/src/main/resources/joinData-2.txt
@@ -0,0 +1,4 @@
+{"InFlow":"10","ProjectName":"ProjectName-0","LogStore":"LogStore-0","OutFlow":"10"}
+{"InFlow":"20","ProjectName":"ProjectName-10","LogStore":"LogStore-10","OutFlow":"10"}
+
+