File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed
datafusion/core/tests/dataframe Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -5344,6 +5344,14 @@ async fn test_insert_into_checking() -> Result<()> {
53445344}
53455345
53465346async fn create_null_table ( ) -> Result < DataFrame > {
5347+ // create a DataFrame with null values
5348+ // "+---+----+",
5349+ // "| a | b |",
5350+ // "+---+---+",
5351+ // "| 1 | x |",
5352+ // "| | |",
5353+ // "| 3 | z |",
5354+ // "+---+---+",
53475355 let schema = Arc :: new ( Schema :: new ( vec ! [
53485356 Field :: new( "a" , DataType :: Int32 , true ) ,
53495357 Field :: new( "b" , DataType :: Utf8 , true ) ,
@@ -5411,6 +5419,7 @@ async fn test_fill_null_all_columns() -> Result<()> {
54115419
54125420 assert_batches_sorted_eq ! ( expected, & results) ;
54135421
5422+ // Fill column "a" null values with a value that cannot be cast to Int32.
54145423 let df_filled = df_filled. fill_null ( ScalarValue :: Int32 ( Some ( 0 ) ) , None ) ?;
54155424
54165425 let results = df_filled. collect ( ) . await ?;
You can’t perform that action at this time.
0 commit comments