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: 维章 <[email protected]> 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"} + +
