func scalarToFlinkJobArg()

in pkg/flink/utils.go [69:76]

• 8 lines of code
• 2 McCabe index (conditional complexity)

func scalarToFlinkJobArg(arg string, scalar *core.Scalar) (string, error) {
	switch s := scalar.GetValue().(type) {
	case *core.Scalar_Primitive:
		return primitiveToFlinkJobArg(arg, s.Primitive)
	default:
		return "", fmt.Errorf("not supported type: %s", s)
	}
}