use Pair class of apache.commons.lang3 (#193)

Author: linfan

rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java

@@ -22,7 +22,7 @@
 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;

rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/operator/AbstractWindow.java

@@ -18,8 +18,8 @@
 
 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 void saveMsgContext(String queueId,WindowInstance windowInstance, List<IM
                 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());