refactor(*): rename go module name

Signed-off-by: ngjaying <ngjaying@gmail.com>

cmd/kuiper/main.go

@@ -3,8 +3,8 @@ package main
 import (
 	"bufio"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/server"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/server"
 	"github.com/urfave/cli"
 	"gopkg.in/yaml.v3"
 	"io/ioutil"

cmd/kuiperd/main.go

@@ -1,6 +1,6 @@
 package main
 
-import "github.com/emqx/kuiper/internal/server"
+import "github.com/lf-edge/ekuiper/internal/server"
 
 var (
 	Version      = "unknown"

docs/en_US/plugins/plugins_tutorial.md

@@ -48,7 +48,7 @@ module samplePlugin
 go 1.16
 
 require (
-	github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+	github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
 )
 ```
 
@@ -70,8 +70,8 @@ package main
 import (
 	"database/sql"
 	"fmt"
-	"github.com/emqx/kuiper/common"
-	"github.com/emqx/kuiper/xstream/api"
+	"github.com/lf-edge/ekuiper/common"
+	"github.com/lf-edge/ekuiper/xstream/api"
 	_ "github.com/go-sql-driver/mysql"
 )
 
@@ -149,7 +149,7 @@ module samplePlugin
 go 1.16
 
 require (
-	github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+	github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
 	github.com/go-sql-driver/mysql v1.5.0
 )
  ```
@@ -164,10 +164,10 @@ Developers can locally compile eKuiper and the plugin for debugging, which steps
 1. Download eKuiper source code: `git clone https://github.com/lf-edge/ekuiper.git`
 2.  Compile eKuiper: run `make` under the eKuiper directory
 3. Compile the plugin:
-    1. Run `go mod edit -replace github.com/emqx/kuiper=$eKuiperPath` under the plugin project, make the eKuiper dependence point to the local eKuiper, and then please replace the download directory of step 1 by $eKuiperPath, the same below.
+    1. Run `go mod edit -replace github.com/lf-edge/ekuiper=$eKuiperPath` under the plugin project, make the eKuiper dependence point to the local eKuiper, and then please replace the download directory of step 1 by $eKuiperPath, the same below.
    2. Because the Golang plugin system has a very strict limitation of the dependency paths, it is more safe to build the plugin from the eKuiper main project. In the eKuiper project, add a new *mod* file with a name like *sample.mod* to point to your plugin project.
       ```
-      module github.com/emqx/kuiper
+      module github.com/lf-edge/ekuiper
       go 1.16
       require samplePlugin v0.0.0
       replace samplePlugin => ../samplePlugin     
@@ -203,7 +203,7 @@ export ETC_TARGET=$EKUIPER_SOURCE/etc
 export ZIP_TARGET=plugins
 export VERSION=0.0.1
 
-go mod edit -replace github.com/emqx/kuiper=$EKUIPER_SOURCE
+go mod edit -replace github.com/lf-edge/ekuiper=$EKUIPER_SOURCE
 
 go build -trimpath --buildmode=plugin -o $PLUGIN_TARGET/sinks/Mysql@v$VERSION.so sinks/mysql.go
 

docs/en_US/plugins/sinks/influx.md

@@ -71,11 +71,11 @@ module plugins
 go 1.14
 
 require (
-        github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+        github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
         github.com/influxdata/influxdb-client-go v1.2.0
         github.com/influxdata/influxdb1-client v0.0.0-20200515024757-02f0bf5dbca3 // indirect
 )
 
-replace github.com/emqx/kuiper => /root/goProject/kuiper
+replace github.com/lf-edge/ekuiper => /root/goProject/kuiper
 
 ```

docs/en_US/plugins/sinks/tdengine.md

@@ -7,16 +7,16 @@ module plugins
 
 go 1.13
 
-replace github.com/emqx/kuiper => /$eKuiper
+replace github.com/lf-edge/ekuiper => /$eKuiper
 
 require (
-    github.com/emqx/kuiper v0.0.0-00010101000000-000000000000 // indirect
+    github.com/lf-edge/ekuiper v0.0.0-00010101000000-000000000000 // indirect
     github.com/taosdata/driver-go v0.0.0-20200723061832-5be6460b0c20
 )
 ```
 
 ```shell
-go mod edit -replace github.com/emqx/kuiper=/$eKuiper
+go mod edit -replace github.com/lf-edge/ekuiper=/$eKuiper
 go build -trimpath -modfile extensions.mod --buildmode=plugin -o /$ekuiper/plugins/sinks/Tdengine@v1.0.0.so /$ekuiper/extensions/sinks/tdengine/tdengine.go
 ```
 ### Install plugin

docs/zh_CN/plugins/plugins_tutorial.md

@@ -48,7 +48,7 @@ module samplePlugin
 go 1.16
 
 require (
-	github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+	github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
 )
 ```
 
@@ -70,8 +70,8 @@ package main
 import (
 	"database/sql"
 	"fmt"
-	"github.com/emqx/kuiper/common"
-	"github.com/emqx/kuiper/xstream/api"
+	"github.com/lf-edge/ekuiper/common"
+	"github.com/lf-edge/ekuiper/xstream/api"
 	_ "github.com/go-sql-driver/mysql"
 )
 
@@ -149,7 +149,7 @@ module samplePlugin
 go 1.16
 
 require (
-	github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+	github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
 	github.com/go-sql-driver/mysql v1.5.0
 )
  ```
@@ -164,10 +164,10 @@ require (
 1. 下载 eKuiper 源代码 `git clone https://github.com/lf-edge/ekuiper.git`
 2. 编译 eKuiper：在 eKuiper 目录下，运行 `make`
 3. 编译插件：
-    1. 在插件项目下，运行 `go mod edit -replace github.com/emqx/kuiper=$eKuiperPath`，使得 eKuiper 依赖指向本地 eKuiper，请替换 $eKuiperPath 到步骤1下载目录，下同。
+    1. 在插件项目下，运行 `go mod edit -replace github.com/lf-edge/ekuiper=$eKuiperPath`，使得 eKuiper 依赖指向本地 eKuiper，请替换 $eKuiperPath 到步骤1下载目录，下同。
     2. 由于 Go 语言插件系统对依赖的路径有非常严格的要求，为了确保插件可以顺利运行，建议在 eKuiper 主项目里进行编译。在 eKuiper 项目里，添加如下名为 sample.mod 的 mod 文件，用于插件编译。
        ```
-       module github.com/emqx/kuiper
+       module github.com/lf-edge/ekuiper
        go 1.16
        require samplePlugin v0.0.0
        replace samplePlugin => ../samplePlugin   
@@ -204,7 +204,7 @@ export ETC_TARGET=$EKUIPER_SOURCE/etc
 export ZIP_TARGET=plugins
 export VERSION=0.0.1
 
-go mod edit -replace github.com/emqx/kuiper=$EKUIPER_SOURCE
+go mod edit -replace github.com/lf-edge/ekuiper=$EKUIPER_SOURCE
 
 go build -trimpath --buildmode=plugin -o $PLUGIN_TARGET/sinks/Mysql@v$VERSION.so sinks/mysql.go
 

docs/zh_CN/plugins/sinks/influx.md

@@ -70,11 +70,11 @@ module plugins
 go 1.14
 
 require (
-        github.com/emqx/kuiper v0.0.0-20200323140757-60d00241372b
+        github.com/lf-edge/ekuiper v0.0.0-20200323140757-60d00241372b
         github.com/influxdata/influxdb-client-go v1.2.0
         github.com/influxdata/influxdb1-client v0.0.0-20200515024757-02f0bf5dbca3 // indirect
 )
 
-replace github.com/emqx/kuiper => /root/goProject/ekuiper
+replace github.com/lf-edge/ekuiper => /root/goProject/ekuiper
 
 ```

docs/zh_CN/plugins/sinks/tdengine.md

@@ -7,16 +7,16 @@ module plugins
 
 go 1.13
 
-replace github.com/emqx/kuiper => /$eKuiper
+replace github.com/lf-edge/ekuiper => /$eKuiper
 
 require (
-    github.com/emqx/kuiper v0.0.0-00010101000000-000000000000 // indirect
+    github.com/lf-edge/ekuiper v0.0.0-00010101000000-000000000000 // indirect
     github.com/taosdata/driver-go v0.0.0-20200723061832-5be6460b0c20
 )
 ```
 
 ```shell
-go mod edit -replace github.com/emqx/kuiper=/$eKuiper
+go mod edit -replace github.com/lf-edge/ekuiper=/$eKuiper
 go build -trimpath -modfile extensions.mod --buildmode=plugin -o /$ekuiper/plugins/sinks/Tdengine@v1.0.0.so /$ekuiper/extensions/sinks/tdengine/tdengine.go
 ```
 ### 安装插件

extensions.mod

@@ -1,4 +1,4 @@
-module github.com/emqx/kuiper
+module github.com/lf-edge/ekuiper
 
 require (
 	github.com/Masterminds/sprig/v3 v3.2.1
@@ -40,9 +40,9 @@ require (
 	google.golang.org/protobuf v1.26.0
 	gopkg.in/ini.v1 v1.62.0
 	gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c
-	github.com/emqx/kuiper/extensions v0.0.0
+	github.com/lf-edge/ekuiper/extensions v0.0.0
 )
 
-replace github.com/emqx/kuiper/extensions => ./extensions
+replace github.com/lf-edge/ekuiper/extensions => ./extensions
 
 go 1.16

extensions.sum

@@ -127,6 +127,7 @@ github.com/lestrrat-go/file-rotatelogs v2.4.0+incompatible h1:Y6sqxHMyB1D2YSzWkL
 github.com/lestrrat-go/file-rotatelogs v2.4.0+incompatible/go.mod h1:ZQnN8lSECaebrkQytbHj4xNgtg8CR7RYXnPok8e0EHA=
 github.com/lestrrat-go/strftime v1.0.3 h1:qqOPU7y+TM8Y803I8fG9c/DyKG3xH/xkng6keC1015Q=
 github.com/lestrrat-go/strftime v1.0.3/go.mod h1:E1nN3pCbtMSu1yjSVeyuRFVm/U0xoR76fd03sz+Qz4g=
+github.com/lf-edge/ekuiper v0.0.0-20210528134227-7e6a6a028a6f/go.mod h1:Cv3+JK88Uv8CVKNQyRLKaFoZz9pPdhuDTZ2nSz/UiOU=
 github.com/mattn/go-pointer v0.0.0-20190911064623-a0a44394634f/go.mod h1:2zXcozF6qYGgmsG+SeTZz3oAbFLdD3OWqnUbNvJZAlc=
 github.com/mattn/go-sqlite3 v1.14.5 h1:1IdxlwTNazvbKJQSxoJ5/9ECbEeaTTyeU7sEAZ5KKTQ=
 github.com/mattn/go-sqlite3 v1.14.5/go.mod h1:WVKg1VTActs4Qso6iwGbiFih2UIHo0ENGwNd0Lj+XmI=

extensions/functions/accumulateWordCount/accumulateWordCount.go

@@ -2,8 +2,8 @@ package main
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"strings"
 )
 

extensions/functions/countPlusOne/countPlusOne.go

@@ -2,7 +2,7 @@ package main
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type countPlusOneFunc struct {

extensions/functions/echo/echo.go

@@ -2,7 +2,7 @@ package main
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type echo struct {

extensions/functions/geohash/geohash.go

@@ -2,7 +2,7 @@ package main
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/mmcloughlin/geohash"
 )
 

extensions/functions/image/resize.go

@@ -3,7 +3,7 @@ package main
 import (
 	"bytes"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/nfnt/resize"
 	"image"
 	"image/jpeg"

extensions/functions/image/thumbnail.go

@@ -3,7 +3,7 @@ package main
 import (
 	"bytes"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/nfnt/resize"
 	"image"
 	"image/jpeg"

extensions/functions/labelImage/labelImage.go

@@ -6,7 +6,7 @@ import (
 	"bufio"
 	"bytes"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	tflite "github.com/mattn/go-tflite"
 	"github.com/nfnt/resize"
 	"image"

extensions/sinks/file/file.go

@@ -4,7 +4,7 @@ import (
 	"bufio"
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"os"
 	"sync"
 	"time"

extensions/sinks/image/image.go

@@ -5,7 +5,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"image/jpeg"
 	"image/png"
 	"io/ioutil"

extensions/sinks/influx/influx.go

@@ -4,9 +4,9 @@ package main
 
 import (
 	"encoding/json"
-	api "github.com/emqx/kuiper/pkg/api"
 	_ "github.com/influxdata/influxdb1-client/v2"
 	client "github.com/influxdata/influxdb1-client/v2"
+	api "github.com/lf-edge/ekuiper/pkg/api"
 	"strings"
 	"time"
 )

extensions/sinks/memory/memory.go

@@ -1,6 +1,6 @@
 package main
 
-import "github.com/emqx/kuiper/pkg/api"
+import "github.com/lf-edge/ekuiper/pkg/api"
 
 type memory struct {
 	results [][]byte

extensions/sinks/tdengine/tdengine.go

@@ -6,9 +6,9 @@ import (
 	"database/sql"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	_ "github.com/taosdata/driver-go/taosSql"
 	"reflect"
 	"strings"

extensions/sinks/zmq/zmq.go

@@ -2,7 +2,7 @@ package main
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	zmq "github.com/pebbe/zmq4"
 )
 

extensions/sources/random/random.go

@@ -4,9 +4,9 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"math/rand"
 	"strings"
 	"time"

extensions/sources/zmq/zmq.go

@@ -3,8 +3,8 @@ package main
 import (
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	zmq "github.com/pebbe/zmq4"
 )
 

go.mod

@@ -1,4 +1,4 @@
-module github.com/emqx/kuiper
+module github.com/lf-edge/ekuiper
 
 require (
 	github.com/Masterminds/sprig/v3 v3.2.1

internal/conf/conf.go

@@ -2,8 +2,8 @@ package conf
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
 	"github.com/lestrrat-go/file-rotatelogs"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/sirupsen/logrus"
 	"gopkg.in/yaml.v3"
 	"io"

internal/conf/time.go

@@ -2,7 +2,7 @@ package conf
 
 import (
 	"github.com/benbjohnson/clock"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"time"
 )
 

internal/pkg/httpx/http.go

@@ -5,8 +5,8 @@ import (
 	"crypto/tls"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"io"
 	"io/ioutil"
 	"net/http"

internal/plugin/funcMeta.go

@@ -2,8 +2,8 @@ package plugin
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
 	"io/ioutil"
 	"path"
 	"strings"

internal/plugin/manager.go

@@ -5,12 +5,12 @@ import (
 	"bytes"
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
-	"github.com/emqx/kuiper/internal/pkg/httpx"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/errorx"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/internal/pkg/httpx"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"io/ioutil"
 	"os"
 	"os/exec"

internal/plugin/manager_test.go

@@ -3,7 +3,7 @@ package plugin
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"net/http"
 	"net/http/httptest"
 	"os"

internal/plugin/msgUtil.go

@@ -1,7 +1,7 @@
 package plugin
 
 import (
-	kconf "github.com/emqx/kuiper/internal/conf"
+	kconf "github.com/lf-edge/ekuiper/internal/conf"
 	"gopkg.in/ini.v1"
 	"io/ioutil"
 	"path"

internal/plugin/sinkMeta.go

@@ -2,9 +2,9 @@ package plugin
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"io/ioutil"
 	"path"
 	"strings"

internal/plugin/sourceMeta.go

@@ -3,9 +3,9 @@ package plugin
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"io/ioutil"
 	"path"
 	"reflect"

internal/processor/rule.go

@@ -4,15 +4,15 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo"
-	"github.com/emqx/kuiper/internal/topo/node"
-	"github.com/emqx/kuiper/internal/topo/planner"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/errorx"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo"
+	"github.com/lf-edge/ekuiper/internal/topo/node"
+	"github.com/lf-edge/ekuiper/internal/topo/planner"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"os"
 	"path"
 )

internal/processor/rule_test.go

@@ -1,7 +1,7 @@
 package processor
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"reflect"
 	"testing"
 )

internal/processor/stream.go

@@ -4,11 +4,11 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/errorx"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"strings"
 )
 

internal/processor/stream_test.go

@@ -2,7 +2,7 @@ package processor
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/testx"
 	"path"
 	"reflect"
 	"testing"

internal/server/rest.go

@@ -4,14 +4,14 @@ import (
 	"crypto/tls"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/plugin"
-	"github.com/emqx/kuiper/internal/service"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/errorx"
 	"github.com/gorilla/handlers"
 	"github.com/gorilla/mux"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	"github.com/lf-edge/ekuiper/internal/service"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
 	"golang.org/x/net/html"
 	"io"
 	"io/ioutil"

internal/server/rpc.go

@@ -4,9 +4,9 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/plugin"
-	"github.com/emqx/kuiper/internal/service"
-	"github.com/emqx/kuiper/internal/topo/sink"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	"github.com/lf-edge/ekuiper/internal/service"
+	"github.com/lf-edge/ekuiper/internal/topo/sink"
 	"strings"
 	"time"
 )

internal/server/ruleManager.go

@@ -5,10 +5,10 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/topo"
-	"github.com/emqx/kuiper/internal/topo/planner"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/errorx"
+	"github.com/lf-edge/ekuiper/internal/topo"
+	"github.com/lf-edge/ekuiper/internal/topo/planner"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/errorx"
 	"sort"
 	"sync"
 )

internal/server/server.go

@@ -1,11 +1,11 @@
 package server
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/plugin"
-	"github.com/emqx/kuiper/internal/processor"
-	"github.com/emqx/kuiper/internal/service"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	"github.com/lf-edge/ekuiper/internal/processor"
+	"github.com/lf-edge/ekuiper/internal/service"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 
 	"context"

internal/service/executors.go

@@ -4,12 +4,12 @@ import (
 	"context"
 	"crypto/tls"
 	"fmt"
-	"github.com/emqx/kuiper/internal/pkg/httpx"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
 	"github.com/golang/protobuf/proto"
 	"github.com/jhump/protoreflect/dynamic"
 	"github.com/jhump/protoreflect/dynamic/grpcdynamic"
+	"github.com/lf-edge/ekuiper/internal/pkg/httpx"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"github.com/ugorji/go/codec"
 	"google.golang.org/grpc"
 	"io/ioutil"

internal/service/externalFunc.go

@@ -1,7 +1,7 @@
 package service
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type ExternalFunc struct {

internal/service/external_service_rule_test.go

@@ -4,13 +4,13 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
-	kconf "github.com/emqx/kuiper/internal/conf"
-	pb "github.com/emqx/kuiper/internal/service/test/schemas/helloworld"
-	"github.com/emqx/kuiper/internal/topo/topotest"
-	"github.com/emqx/kuiper/pkg/api"
 	"github.com/golang/protobuf/ptypes/empty"
 	"github.com/golang/protobuf/ptypes/wrappers"
 	"github.com/gorilla/mux"
+	kconf "github.com/lf-edge/ekuiper/internal/conf"
+	pb "github.com/lf-edge/ekuiper/internal/service/test/schemas/helloworld"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/msgpack-rpc/msgpack-rpc-go/rpc"
 	"google.golang.org/grpc"
 	"io"

internal/service/manager.go

@@ -3,11 +3,11 @@ package service
 import (
 	"archive/zip"
 	"fmt"
-	kconf "github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/pkg/filex"
-	"github.com/emqx/kuiper/internal/pkg/httpx"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/kv"
+	kconf "github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/pkg/filex"
+	"github.com/lf-edge/ekuiper/internal/pkg/httpx"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"io/ioutil"
 	"os"
 	"path"

internal/service/manager_test.go

@@ -1,7 +1,7 @@
 package service
 
 import (
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"reflect"
 	"testing"
 )

internal/service/schema.go

@@ -3,14 +3,14 @@ package service
 import (
 	"encoding/json"
 	"fmt"
-	kconf "github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/cast"
 	"github.com/golang/protobuf/proto"
 	dpb "github.com/golang/protobuf/protoc-gen-go/descriptor"
 	"github.com/jhump/protoreflect/desc"
 	"github.com/jhump/protoreflect/desc/protoparse"
 	"github.com/jhump/protoreflect/dynamic"
+	kconf "github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	_ "google.golang.org/genproto/googleapis/api/annotations"
 	"sync"
 )

internal/service/schemaHttp.go

@@ -2,10 +2,10 @@ package service
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/cast"
 	dpb "github.com/golang/protobuf/protoc-gen-go/descriptor"
 	"github.com/jhump/protoreflect/desc"
 	"github.com/jhump/protoreflect/dynamic"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"google.golang.org/protobuf/reflect/protoreflect"
 	"net/http"
 	"regexp"

internal/service/schemaHttp_test.go

@@ -1,7 +1,7 @@
 package service
 
 import (
-	"github.com/emqx/kuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/testx"
 	"net/http"
 	"reflect"
 	"testing"

internal/service/schema_test.go

@@ -1,7 +1,7 @@
 package service
 
 import (
-	"github.com/emqx/kuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/testx"
 	"reflect"
 	"testing"
 )

internal/template/funcs_test.go

@@ -3,7 +3,7 @@ package template
 import (
 	"encoding/base64"
 	"fmt"
-	"github.com/emqx/kuiper/internal/testx"
+	"github.com/lf-edge/ekuiper/internal/testx"
 	"reflect"
 	"testing"
 )

internal/testx/testUtil.go

@@ -1,7 +1,7 @@
 package testx
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/conf"
 )
 
 // errstring returns the string representation of an error.

internal/topo/checkpoint/barrier_handler.go

@@ -1,7 +1,7 @@
 package checkpoint
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type BarrierHandler interface {

internal/topo/checkpoint/coordinator.go

@@ -2,9 +2,9 @@ package checkpoint
 
 import (
 	"github.com/benbjohnson/clock"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"sync"
 )
 

internal/topo/checkpoint/defs.go

@@ -1,7 +1,7 @@
 package checkpoint
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type StreamTask interface {

internal/topo/collector/func.go

@@ -2,7 +2,7 @@ package collector
 
 import (
 	"errors"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 // CollectorFunc is a function used to colllect

internal/topo/context/default.go

@@ -3,9 +3,9 @@ package context
 import (
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"github.com/sirupsen/logrus"
 	"sync"
 	"time"

internal/topo/context/default_test.go

@@ -1,9 +1,9 @@
 package context
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/state"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/state"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"log"
 	"os"
 	"path"

internal/topo/context/func_context.go

@@ -2,7 +2,7 @@ package context
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 type DefaultFuncContext struct {

internal/topo/node/dynamic_channel_buffer.go

@@ -1,7 +1,7 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"sync/atomic"
 )
 

internal/topo/node/join_align_node.go

@@ -2,8 +2,8 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 // JoinAlignNode will block the stream and buffer all the table tuples. Once buffered, it will combine the later input with the buffer

internal/topo/node/node.go

@@ -2,10 +2,10 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/checkpoint"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/checkpoint"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"gopkg.in/yaml.v3"
 	"strings"
 	"sync"

internal/topo/node/operations.go

@@ -2,8 +2,8 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"sync"
 )
 

internal/topo/node/sink_cache.go

@@ -3,10 +3,10 @@ package node
 import (
 	"encoding/gob"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/checkpoint"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/kv"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/checkpoint"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/kv"
 	"io"
 	"path"
 	"sort"

internal/topo/node/sink_node.go

@@ -4,12 +4,12 @@ import (
 	"bytes"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/plugin"
-	ct "github.com/emqx/kuiper/internal/template"
-	"github.com/emqx/kuiper/internal/topo/sink"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	ct "github.com/lf-edge/ekuiper/internal/template"
+	"github.com/lf-edge/ekuiper/internal/topo/sink"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"sync"
 	"text/template"
 	"time"

internal/topo/node/sink_node_test.go

@@ -2,9 +2,9 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/topo/topotest/mocknode"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mocknode"
 	"reflect"
 	"testing"
 	"time"

internal/topo/node/source_node.go

@@ -1,13 +1,13 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/plugin"
-	"github.com/emqx/kuiper/internal/topo/source"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/plugin"
+	"github.com/lf-edge/ekuiper/internal/topo/source"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"sync"
 )
 

internal/topo/node/source_node_test.go

@@ -1,10 +1,10 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"testing"
 )

internal/topo/node/source_pool.go

@@ -3,9 +3,9 @@ package node
 import (
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	kctx "github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	kctx "github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"sync"
 )
 

internal/topo/node/source_pool_test.go

@@ -1,11 +1,11 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/topo/state"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/topo/state"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"testing"
 )
 

internal/topo/node/sources_for_test_with_edgex.go

@@ -4,10 +4,10 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/topo/sink"
-	"github.com/emqx/kuiper/internal/topo/source"
-	"github.com/emqx/kuiper/internal/topo/topotest/mocknode"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/topo/sink"
+	"github.com/lf-edge/ekuiper/internal/topo/source"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mocknode"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 func getSource(t string) (api.Source, error) {

internal/topo/node/sources_for_test_without_edgex.go

@@ -4,8 +4,8 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/topo/topotest/mocknode"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/topo/topotest/mocknode"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 func getSource(t string) (api.Source, error) {

internal/topo/node/sources_with_edgex.go

@@ -4,9 +4,9 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/internal/topo/sink"
-	"github.com/emqx/kuiper/internal/topo/source"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/topo/sink"
+	"github.com/lf-edge/ekuiper/internal/topo/source"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 func getSource(t string) (api.Source, error) {

internal/topo/node/sources_without_edgex.go

@@ -4,7 +4,7 @@
 package node
 
 import (
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 func getSource(t string) (api.Source, error) {

internal/topo/node/stats_manager.go

@@ -2,8 +2,8 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/pkg/api"
 	"github.com/prometheus/client_golang/prometheus"
 	"strconv"
 	"time"

internal/topo/node/watermark.go

@@ -3,9 +3,9 @@ package node
 import (
 	"context"
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"math"
 	"sort"
 )

internal/topo/node/window_op.go

@@ -4,11 +4,11 @@ import (
 	"encoding/gob"
 	"fmt"
 	"github.com/benbjohnson/clock"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"math"
 	"time"
 )

internal/topo/node/window_op_test.go

@@ -2,7 +2,7 @@ package node
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"reflect"
 	"testing"
 )

internal/topo/operator/aggregate_operator.go

@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 type AggregateOp struct {

internal/topo/operator/aggregate_test.go

@@ -3,10 +3,10 @@ package operator
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"

internal/topo/operator/field_processor.go

@@ -4,10 +4,10 @@ import (
 	"encoding/base64"
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"math"
 	"reflect"
 	"strconv"

internal/topo/operator/filter_operator.go

@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 type FilterOp struct {

internal/topo/operator/filter_test.go

@@ -3,10 +3,10 @@ package operator
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"

internal/topo/operator/having_operator.go

@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 type HavingOp struct {

internal/topo/operator/having_test.go

@@ -3,9 +3,9 @@ package operator
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"reflect"
 	"strings"
 	"testing"

internal/topo/operator/join_multi_test.go

@@ -2,10 +2,10 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 	"reflect"
 	"strings"
 	"testing"

internal/topo/operator/join_operator.go

@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 //TODO join expr should only be the equal op between 2 streams like tb1.id = tb2.id

internal/topo/operator/join_test.go

@@ -4,11 +4,11 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"

internal/topo/operator/math_func_test.go

@@ -3,9 +3,9 @@ package operator
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"reflect"
 	"strings"
 	"testing"

internal/topo/operator/misc_func_test.go

@@ -3,9 +3,9 @@ package operator
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
 	"reflect"
 	"strings"
 	"testing"

internal/topo/operator/order_operator.go

@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
 )
 
 type OrderOp struct {

internal/topo/operator/order_test.go

@@ -3,10 +3,10 @@ package operator
 import (
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"

internal/topo/operator/preprocessor.go

@@ -2,9 +2,9 @@ package operator
 
 import (
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"strings"
 )
 

internal/topo/operator/preprocessor_test.go

@@ -5,12 +5,12 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"io/ioutil"
 	"log"
 	"path"

internal/topo/operator/project_operator.go

@@ -3,10 +3,10 @@ package operator
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/api"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/message"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/api"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/message"
 	"strings"
 )
 

internal/topo/operator/project_test.go

@@ -4,11 +4,11 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/ast"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/ast"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"

internal/topo/operator/str_func_test.go

@@ -3,10 +3,10 @@ package operator
 import (
 	"encoding/json"
 	"fmt"
-	"github.com/emqx/kuiper/internal/conf"
-	"github.com/emqx/kuiper/internal/topo/context"
-	"github.com/emqx/kuiper/internal/xsql"
-	"github.com/emqx/kuiper/pkg/cast"
+	"github.com/lf-edge/ekuiper/internal/conf"
+	"github.com/lf-edge/ekuiper/internal/topo/context"
+	"github.com/lf-edge/ekuiper/internal/xsql"
+	"github.com/lf-edge/ekuiper/pkg/cast"
 	"reflect"
 	"strings"
 	"testing"