func literalMapToFlinkJobArgs()

in pkg/flink/utils.go [23:34]


func literalMapToFlinkJobArgs(literals map[string]*core.Literal) ([]string, error) {
	args := []string{}
	for key, literal := range literals {
		ls, err := literalToFlinkJobArg(key, literal)
		if err != nil {
			return nil, err
		}

		args = append(args, ls...)
	}
	return args, nil
}