将值传递给来自python的livy

问题描述 投票:1回答:1

我想将值传递给python中的livy代码。但是我传递的值在每次调用后都会发生变化,但是传给livy的值仍然相同。

data_while_loop = {
    'code': textwrap.dedent("""
    user_data_dict = """ + str(user_ver_dict) + """
    """
}

i = 0
map = {}
while i<10:
   map['x'] = i
   "statement to call value and pass map to livy code"
   i+=1

但是第一次迭代中的值与预期的一样。但不是在后续的迭代中。当map ['x']在livy的代码中传递时。在while循环中,map ['x']的值被发送到livy的代码上面。

python apache-spark pyspark livy
1个回答
0
投票

我通过在map ['x'] = i命令之后移动while循环中的data_while_loop变量来解决问题。这基本上会在每次调用data_while_loop时覆盖,并且map变量的最新值将传递给livy代码。

© www.soinside.com 2019 - 2024. All rights reserved.