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 dce47e2d45c7eef4e17edcec6039648fd3e21848 Author: 刈刀 <[email protected]> AuthorDate: Tue Aug 3 14:41:11 2021 +0800 add QUICKSTART.md --- QUICKSTART.md | 81 ++++++++++++++++++++++ .../common/checkpoint/CheckPointMessage.java | 11 +-- 2 files changed, 84 insertions(+), 8 deletions(-) diff --git a/QUICKSTART.md b/QUICKSTART.md new file mode 100644 index 0000000..9e33842 --- /dev/null +++ b/QUICKSTART.md @@ -0,0 +1,81 @@ +# Quick Start + +本文档详细介绍了如何在rocketmq上执行流计算任务； + +## 所需环境 + ++ 64bit OS, Linux/Unix/Mac is recommended;(Windows user see guide below) ++ 64bit JDK 1.8+; ++ Maven 3.2.X + +## 使用步骤 + +### 1. 创建maven项目， 并依赖rocketmq-streams的客户端 + +```xml + +<dependency> + <groupId>org.apache.rocketmq</groupId> + <artifactId>rocketmq-streams-clients</artifactId> + <version>2.0.0-SNAPSHOT</version> +</dependency> +``` + +### 2. 在主函数中按照streams的开发规范，编写业务逻辑 + +```java +import org.apache.rocketmq.streams.client.transform.DataStream; + +public static void main(String[]args){ + DataStreamSource source=StreamBuilder.dataStream("namespace","pipeline"); + + source + .fromFile("～/admin/data/text.txt",false) + .map(message->message) + .toPrint(1) + .start(); + } +``` + +### 3. 在pom.xml中加入shade插件， 将依赖的stream与业务代码一并打包， 形成-shaded.jar 包 + +```xml + +<plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-shade-plugin</artifactId> + <version>3.2.1</version> + <executions> + <execution> + <phase>package</phase> + <goals> + <goal>shade</goal> + </goals> + <configuration> + <minimizeJar>false</minimizeJar> + <shadedArtifactAttached>true</shadedArtifactAttached> + <artifactSet> + <includes> + <include>org.apache.rocketmq:rocketmq-streams-clients</include> + </includes> + </artifactSet> + </configuration> + </execution> + </executions> +</plugin> + +``` + +### 4. 将jar包拷贝到应用服务器，作为普通的java应用直接运行 + +``` + java -jar XXXX-shade.jar \ + -Dlog4j.level=ERROR \ + -Dlog4j.home=/logs \ + -Xms1024m \ + -Xmx1024m +``` + + + + diff --git a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointMessage.java b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointMessage.java index 975ccb8..70cee61 100644 --- a/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointMessage.java +++ b/rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointMessage.java @@ -16,17 +16,12 @@ */ package org.apache.rocketmq.streams.common.checkpoint; -import java.util.ArrayList; -import java.util.List; -import java.util.Map; -import java.util.Set; - -import javafx.stage.Stage; import org.apache.rocketmq.streams.common.channel.source.ISource; import org.apache.rocketmq.streams.common.interfaces.IStreamOperator; import org.apache.rocketmq.streams.common.interfaces.ISystemMessage; -import org.apache.rocketmq.streams.common.topology.ChainPipeline; -import org.apache.rocketmq.streams.common.topology.ChainStage; + +import java.util.ArrayList; +import java.util.List; public class CheckPointMessage implements ISystemMessage { protected ISource source;//数据源对象
