小编Ben*_*ish的帖子

GO中自定义类型的ENUM

我正在尝试为我定义的类型生成枚举

type FeeStage int
Run Code Online (Sandbox Code Playgroud)

这个我知道,我可以用丝毫基于这种类型来创建一个枚举

const(
     Stage1 FeeStage = iota
     Stage2 
     Stage3
)
Run Code Online (Sandbox Code Playgroud)

但是,操纵枚举的实际值是相当麻烦且容易出错的

const(
     Stage1 FeeStage = iota           // 0
     Stage2          = iota + 6       // 7
     Stage3          = (iota - 3) * 5 // -5
)
Run Code Online (Sandbox Code Playgroud)

有没有办法自动将带有自定义值的ENUM列表转换为某种类型.这是我以前使用的,但只将常量的第一个成员转换为自定义类型.

const(
     Stage1 FeeStage = 1
     Stage2          = 2
     Stage3          = 2
)
Run Code Online (Sandbox Code Playgroud)

是一个结果相似的游乐场

enums go iota

4
推荐指数
1
解决办法
1900
查看次数

Flink字数统计示例缺少库

我正在尝试使用Flink运行示例程序。我使用下载了示例项目

mvn archetype:generate -DarchetypeGroupId=org.apache.flink -DarchetypeArtifactId=flink-quickstart-scala -DarchetypeVersion=0.8.1

然后,我在终端上运行以下命令

mvn package && java -cp target/test-1.0-SNAPSHOT.jar adfin.WordCount

我收到以下错误

线程“主要”中的异常java.lang.NoClassDefFoundError:adfin.WordCount.main(WordCount.scala)处的org / apache / flink / api / common / typeinfo / TypeInformation造成原因:java.lang.ClassNotFoundException:org.apache.flink .api.common.typeinfo.TypeInformation at java.net.URLClassLoader.findClass(URLClassLoader.java:381)at java.lang.ClassLoader.loadClass(ClassLoader.java:424)at sun.misc.Launcher $ AppClassLoader.loadClass(Launcher .java:331),位于java.lang.ClassLoader.loadClass(ClassLoader.java:357)

我尝试将库从默认的0.8.1更新为1.0.0,但这没有任何改变。我想可能需要添加一个额外的jar。有人可以帮忙吗?

scala maven apache-flink

2
推荐指数
1
解决办法
1595
查看次数

将管道读取写入 golang 中的 http 响应

这是架构:

客户端向服务器 A 发送 POST 请求

服务器 A 处理这个并向服务器 B 发送一个 GET

服务器 B 通过 A 向客户端发送响应


我虽然最好的想法是制作一个管道来读取 GET 的响应,并写入 POST 的响应,但我遇到了很多类型的问题。

func main() {
    r := mux.NewRouter()
    r.HandleFunc("/test/{hash}", testHandler)

    log.Fatal(http.ListenAndServe(":9095", r))
}

func handleErr(err error) {
    if err != nil {
        log.Fatalf("%s\n", err)
    }
}


func testHandler(w http.ResponseWriter, r *http.Request){

    fmt.Println("FIRST REQUEST RECEIVED")
    vars := mux.Vars(r)
    hash := vars["hash"]
    read, write := io.Pipe()

    // writing without a reader will deadlock so write in a goroutine
    go func() {
        write, …
Run Code Online (Sandbox Code Playgroud)

http pipe go mux

1
推荐指数
1
解决办法
5251
查看次数

标签 统计

go ×2

apache-flink ×1

enums ×1

http ×1

iota ×1

maven ×1

mux ×1

pipe ×1

scala ×1