File tree 1 file changed +6
-2
lines changed
1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -906,18 +906,22 @@ def insert(
906
906
)
907
907
return self .raw_sql (statement .compile ())
908
908
909
+ identifier = sg .table (
910
+ table_name , db = database , catalog = catalog , quoted = self .compiler .quoted
911
+ ).sql (self .dialect )
912
+
909
913
if isinstance (obj , pa .Table ):
910
914
obj = obj .to_pandas ()
911
915
if isinstance (obj , dict ):
912
916
obj = pd .DataFrame .from_dict (obj )
913
917
if isinstance (obj , pd .DataFrame ):
914
918
table = self ._table_env .from_pandas (obj )
915
- return table .execute_insert (table_name , overwrite = overwrite )
919
+ return table .execute_insert (identifier , overwrite = overwrite )
916
920
917
921
if isinstance (obj , list ):
918
922
# pyflink infers datatypes, which may sometimes result in incompatible types
919
923
table = self ._table_env .from_elements (obj )
920
- return table .execute_insert (table_name , overwrite = overwrite )
924
+ return table .execute_insert (identifier , overwrite = overwrite )
921
925
922
926
raise ValueError (
923
927
"No operation is being performed. Either the obj parameter "
You can’t perform that action at this time.
0 commit comments