<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-streams-clients</artifactId> </dependency>
public class RocketmqExample { public static void main(String[] args) { DataStreamSource dataStream = StreamBuilder.dataStream("test_namespace", "graph_pipeline"); dataStream .fromFile("data.csv", false) //构建实时任务的数据源 .map(message -> message.split(",")) //构建实时任务处理的逻辑过程 .toPrint(1) //构建实时任务的输出 .start(); //启动实时任务 } }
打包
mvn -Prelease-all -DskipTests clean install -U
运行
java -jar jarName mainClass