Skip to content

Commit 7c56707

Browse files
authored
Merge branch 'main' into aalam-SNOW-2257191-cte-join-bugfix
2 parents b442092 + 6a7ab60 commit 7c56707

48 files changed

Lines changed: 3370 additions & 246 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

CHANGELOG.md

Lines changed: 59 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,11 @@
44

55
### Snowpark Python API Updates
66

7+
#### Bug Fixes
8+
9+
- Fixed a bug that `DataFrame.limit()` fail if there is parameter binding in the executed SQL.
10+
- Added an experimental fix for a bug in schema query generation that could cause invalid sql to be genrated when using nested structured types.
11+
712
#### New Features
813

914
- Added a new module `snowflake.snowpark.secrets` that provides Python wrappers for accessing Snowflake Secrets within Python UDFs and stored procedures that execute inside Snowflake.
@@ -12,14 +17,65 @@
1217
- `get_secret_type`
1318
- `get_username_password`
1419
- `get_cloud_provider_token`
20+
- Added support for the following scalar functions in `functions.py`:
21+
- `array_remove_at`
22+
- `as_boolean`
23+
- `booland`
24+
- `boolnot`
25+
- `boolor`
26+
- `boolor_agg`
27+
- `boolxor`
28+
- `chr`
29+
- `decode`
30+
- `div0null`
31+
- `dp_interval_high`
32+
- `dp_interval_low`
33+
- `greatest_ignore_nulls`
34+
- `h3_cell_to_boundary`
35+
- `h3_cell_to_children`
36+
- `h3_cell_to_children_string`
37+
- `h3_cell_to_parent`
38+
- `h3_cell_to_point`
39+
- `h3_compact_cells`
40+
- `h3_compact_cells_strings`
41+
- `h3_coverage`
42+
- `h3_coverage_strings`
43+
- `h3_get_resolution`
44+
- `h3_grid_disk`
45+
- `h3_grid_distance`
46+
- `h3_int_to_string`
47+
- `h3_polygon_to_cells`
48+
- `h3_polygon_to_cells_strings`
49+
- `h3_string_to_int`
50+
- `h3_try_grid_path`
51+
- `h3_try_polygon_to_cells`
52+
- `h3_try_polygon_to_cells_strings`
53+
- `h3_uncompact_cells`
54+
- `h3_uncompact_cells_strings`
55+
- `haversine`
56+
- `hex_decode_binary`
57+
- `last_query_id`
58+
- `last_transaction`
59+
- `least_ignore_nulls`
60+
- `nullif`
61+
- `nvl2`
62+
- `regr_valx`
63+
- `st_area`
64+
- `st_asewkb`
65+
- `st_asewkt`
66+
- `st_asgeojson`
67+
- `st_aswkb`
1568

1669
#### Bug Fixes
1770

1871
- Fixed an issue where DataFrame joins would fail when CTE optimization was enabled and one of the DataFrames was created using the `DataFrame.alias()` method.
1972

73+
2074
### Snowpark pandas API Updates
2175

2276
#### New Features
77+
- Added support for `DataFrame.query` for dataframes with single-level indexes.
78+
- Added support for `DataFrameGroupby.__len__` and `SeriesGroupBy.__len__`.
2379

2480
#### Improvements
2581

@@ -62,6 +118,7 @@
62118
- `create_or_replace_dynamic_table`
63119
- Added a new function `snowflake.snowpark.functions.vectorized` that allows users to mark a function as vectorized UDF.
64120
- Added support for parameter `use_vectorized_scanner` in function `Session.write_pandas()`.
121+
- Added support for parameter `session_init_statement` in udtf ingestion of `DataFrameReader.jdbc`(PrPr).
65122
- Added support for the following scalar functions in `functions.py`:
66123
- `getdate`
67124
- `getvariable`
@@ -76,6 +133,8 @@
76133

77134
#### Bug Fixes
78135

136+
- Fixed a bug that `query_timeout` does not work in udtf ingestion of `DataFrameReader.jdbc`(PrPr).
137+
79138
#### Deprecations
80139

81140
- Deprecated warnings will be triggered when using snowpark-python with Python 3.9. For more details, please refer to https://docs.snowflake.com/en/developer-guide/python-runtime-support-policy.

docs/source/modin/supported/dataframe_supported.rst

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -332,7 +332,7 @@ Methods
332332
| | | | ``"linear"`` or ``"nearest"``, and ``method`` is |
333333
| | | | ``"single"``. |
334334
+-----------------------------+---------------------------------+----------------------------------+----------------------------------------------------+
335-
| ``query`` | N | | |
335+
| ``query`` | P | | No support for dataframes with a row MultiIndex. |
336336
+-----------------------------+---------------------------------+----------------------------------+----------------------------------------------------+
337337
| ``radd`` | P | ``level`` | |
338338
+-----------------------------+---------------------------------+----------------------------------+----------------------------------------------------+

docs/source/modin/supported/groupby_supported.rst

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -121,6 +121,8 @@ Computations/descriptive stats
121121
+-----------------------------+---------------------------------+----------------------------------------------------+
122122
| ``last`` | P | Does not support ``min_count`` parameter |
123123
+-----------------------------+---------------------------------+----------------------------------------------------+
124+
| ``__len__`` | Y | |
125+
+-----------------------------+---------------------------------+----------------------------------------------------+
124126
| ``max`` | Y | See ``count`` |
125127
+-----------------------------+---------------------------------+----------------------------------------------------+
126128
| ``mean`` | Y | See ``count`` |

docs/source/snowpark/functions.rst

Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,7 @@ Functions
5959
array_position
6060
array_prepend
6161
array_remove
62+
array_remove_at
6263
array_reverse
6364
array_size
6465
array_slice
@@ -70,6 +71,7 @@ Functions
7071
arrays_zip
7172
as_array
7273
as_binary
74+
as_boolean
7375
as_char
7476
as_date
7577
as_decimal
@@ -109,6 +111,11 @@ Functions
109111
bitshiftright
110112
bitxor
111113
bitxor_agg
114+
boolor_agg
115+
booland
116+
boolnot
117+
boolor
118+
boolxor
112119
build_stage_file_url
113120
builtin
114121
bround
@@ -123,6 +130,7 @@ Functions
123130
charindex
124131
check_json
125132
check_xml
133+
chr
126134
coalesce
127135
col
128136
collate
@@ -180,13 +188,16 @@ Functions
180188
dayofmonth
181189
dayofweek
182190
dayofyear
191+
decode
183192
degrees
184193
dense_rank
185194
desc
186195
desc_nulls_first
187196
desc_nulls_last
188197
div0
189198
divnull
199+
dp_interval_high
200+
dp_interval_low
190201
editdistance
191202
endswith
192203
equal_nan
@@ -223,12 +234,36 @@ Functions
223234
getdate
224235
getvariable
225236
greatest
237+
greatest_ignore_nulls
226238
grouping
227239
grouping_id
228240
hash
241+
haversine
229242
hex
243+
hex_decode_binary
230244
hex_encode
231245
hour
246+
h3_cell_to_boundary
247+
h3_cell_to_parent
248+
h3_cell_to_point
249+
h3_compact_cells
250+
h3_compact_cells_strings
251+
h3_coverage
252+
h3_coverage_strings
253+
h3_get_resolution
254+
h3_grid_disk
255+
h3_grid_distance
256+
h3_polygon_to_cells
257+
h3_polygon_to_cells_strings
258+
h3_string_to_int
259+
h3_try_polygon_to_cells_strings
260+
h3_cell_to_children
261+
h3_cell_to_children_string
262+
h3_int_to_string
263+
h3_try_grid_path
264+
h3_try_polygon_to_cells
265+
h3_uncompact_cells
266+
h3_uncompact_cells_strings
232267
iff
233268
ifnull
234269
in_
@@ -265,9 +300,12 @@ Functions
265300
kurtosis
266301
lag
267302
last_day
303+
last_query_id
304+
last_transaction
268305
last_value
269306
lead
270307
least
308+
least_ignore_nulls
271309
left
272310
length
273311
listagg
@@ -308,8 +346,10 @@ Functions
308346
not_
309347
nth_value
310348
ntile
349+
nullif
311350
nullifzero
312351
nvl
352+
nvl2
313353
object_agg
314354
object_construct
315355
object_construct_keep_null
@@ -346,6 +386,7 @@ Functions
346386
regr_sxx
347387
regr_sxy
348388
regr_syy
389+
regr_valx
349390
repeat
350391
replace
351392
right
@@ -380,6 +421,11 @@ Functions
380421
strip_null_value
381422
strtok_to_array
382423
struct
424+
st_area
425+
st_asewkb
426+
st_asewkt
427+
st_asgeojson
428+
st_aswkb
383429
substr
384430
substring
385431
sum

0 commit comments

Comments
 (0)