[rocketmq-streams] branch main updated: use Pair class of apache.commons.lang3 (#193)

[du...@apache.org]

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


The following commit(s) were added to refs/heads/main by this push:
     new a9fe443d use Pair class of apache.commons.lang3 (#193)
a9fe443d is described below

commit a9fe443db230aed46ad2bb22eda831948d4a0b92
Author: Fan Lin <li...@gmail.com>
AuthorDate: Sat Jul 9 09:45:07 2022 +0800

    use Pair class of apache.commons.lang3 (#193)
---
 .../org/apache/rocketmq/streams/client/transform/WindowStream.java    | 2 +-
 .../org/apache/rocketmq/streams/window/operator/AbstractWindow.java   | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java b/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java
index 24fdf175..91f539dd 100644
--- a/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java
+++ b/rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java
@@ -22,7 +22,7 @@ import java.util.List;
 import java.util.Map;
 import java.util.Properties;
 import java.util.Set;
-import javafx.util.Pair;
+import org.apache.commons.lang3.tuple.Pair;
 import org.apache.rocketmq.streams.client.transform.window.Time;
 import org.apache.rocketmq.streams.common.channel.builder.IChannelBuilder;
 import org.apache.rocketmq.streams.common.channel.sink.ISink;
diff --git a/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/AbstractWindow.java b/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/AbstractWindow.java
index 817401f1..b0234f55 100644
--- a/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/AbstractWindow.java
+++ b/rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/AbstractWindow.java
@@ -18,8 +18,8 @@ package org.apache.rocketmq.streams.window.operator;
 
 import com.alibaba.fastjson.JSONObject;
 
-import javafx.util.Pair;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.commons.lang3.tuple.Pair;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.rocketmq.streams.common.channel.sink.ISink;
@@ -831,7 +831,7 @@ public abstract class AbstractWindow extends BasedConfigurable implements IAfter
                 for(IMessage message:messages){
                     JSONObject msg=message.getMessageBody();
                     try {
-                        msg=this.mapFunction.map(new Pair(windowInstance,msg));
+                        msg=this.mapFunction.map(Pair.of(windowInstance, msg));
                         Message copyMsg=new Message(msg);
                         copyMsg.getHeader().setQueueId(queueId);
                         copyMsg.getHeader().setOffset(message.getHeader().getOffset());