Remove the deprecated vendor folder

apache-beam-analysis/MQTT_Publisher/testmachine.go

@@ -1,12 +1,12 @@
 package main
 
 import (
-	"time"
-	"fmt"
 	"encoding/json"
+	"fmt"
+	"time"
 
 	"github.com/yosssi/gmq/mqtt"
-	"github.com/yosssi/gmq/mqtt/client"	
+	"github.com/yosssi/gmq/mqtt/client"
 )
 
 type ReadDataFn struct {
@@ -52,7 +52,7 @@ func main() {
 	for i = 0; i < 20; i++ {
 		time.Sleep(2 * time.Second)
 		Data.ID = i
-		Data.CreateTime = time.Now().Local()	
+		Data.CreateTime = time.Now().Local()
 		if i == 1 {
 			Data.Value = "90"
 			Data.MachineID = "M2000"

apache-beam-analysis/go.mod

@@ -0,0 +1,5 @@
+module github.com/kubeedge/examples/apache-beam-analysis
+
+go 1.16
+
+require github.com/yosssi/gmq v0.0.1

apache-beam-analysis/go.sum

@@ -0,0 +1,2 @@
+github.com/yosssi/gmq v0.0.1 h1:GhlDVaAQoi3Mvjul/qJXXGfL4JBeE0GQwbWp3eIsja8=
+github.com/yosssi/gmq v0.0.1/go.mod h1:mReykazh0U1JabvuWh1PEbzzJftqOQWsjr0Lwg5jL1Y=

ke-twitter-demo/Pi_app/offline.go

@@ -1,10 +1,10 @@
 package main
 
 import (
+	"encoding/json"
 	"flag"
 	"fmt"
 	"time"
-	"encoding/json"
 
 	"github.com/yosssi/gmq/mqtt"
 	"github.com/yosssi/gmq/mqtt/client"
@@ -39,11 +39,11 @@ func main() {
 
 	data := types.DeviceTwinUpdate{}
 	data.EventID = "12345"
-	data.Timestamp = time.Now().Unix()/1e6
+	data.Timestamp = time.Now().Unix() /1e6
 	data.Twin = map[string]*types.MsgTwin{"track": &types.MsgTwin{Expected:&types.TwinValue{Value:songname, Metadata:&types.ValueMetadata{Timestamp: time.Now().Unix()/1e6}}, Optional: &optional, Metadata:&types.TypeMetadata{Type:"string"}, ExpectedVersion: &types.TwinVersion{CloudVersion: 22022, EdgeVersion:0}}}
 
 	// Publish a message.
-	bytes,_:=json.Marshal(data)
+	bytes, _ := json.Marshal(data)
 	fmt.Println(string(bytes))
 	err = cli.Publish(&client.PublishOptions{
 		QoS:       mqtt.QoS0,
@@ -54,7 +54,7 @@ func main() {
 		panic(err)
 	}
 
-	time.Sleep(2*time.Second)
+	time.Sleep(2 * time.Second)
 	// Disconnect the Network Connection.
 	if err := cli.Disconnect(); err != nil {
 		panic(err)