问题1：
我已经生成了一个Table对象main_table，我如何才能取其中的字段'data'中的值，加入条件判断语句中呢，没找到有合适的api
例如：
if main_table.to_pandas()['data'].iloc[0] == '': #我现在是通过转成pandas来操作，还有其他好用的方法吗
......
问题2：
full_outer_join(right, join_predicate)[source]¶
Joins two Table. Similar to a SQL full outer join. The fields of the two joined
operations must not overlap, use alias() to rename fields if necessary.
Note
Both tables must be bound to the same TableEnvironment and its TableConfig must
have null check enabled (default).
Example:
>>> left.full_outer_join(right,"a = b").select("a, b, d")
Parameters
right (pyflink.table.Table) – Right table.
join_predicate (str) – The join predicate expression string.
Returns
The result table.
Return type
pyflink.table.Table
The fields of the two joined operations must not
overlap是什么意思，sql中的full_outer_join例如：
SELECT Persons.LastName, Persons.FirstName, Orders.OrderNo
FROM Persons
FULL JOIN Orders
ON Persons.Id_P=Orders.Id_P
#on中的两个表的字段是可以重复的，The fields of the two joined operations must not
overlap意思是做匹配的两个字段名不能重复吗
在 2020-09-09 15:54:35，"nicholasjiang" <[email protected]> 写道：
>1.最终发现只insert了main_table,请问遇见这种情况该怎么处理，就是如何插入多个表？
>针对Multiple Sink的话推荐通过Statement Set方式：
>statement_set = TableEnvironment.create_statement_set()
>main_table = source.select(".......")
>sub_table = source.select(".......")
>statement_set.add_insert("main_table", main_table)
>statement_set.add_insert("sub_table", sub_table)
>
>2.for i in range(1,20):
> sub_table = source.select("...%s...%d...."
>%(str(i),i))#我的select语句是一个动态拼接的sql，在一个for循环中，获取多个sub_table
>
>sub_table.execute_insert('sink').get_job_client().get_job_execution_result().result()
>#这种方式是否合理，因为也是测试无法插入多个表，有没有什么解决方案
>按照上述方式进行Multiple Sink是可以插入多个表。
>
>
>
>--
>Sent from: http://apache-flink.147419.n8.nabble.com/
