File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -65,7 +65,9 @@ impl ScalarUDFImpl for JsonAsText {
6565 // then we can push this UDF down to the leaf nodes.
6666 if args. len ( ) >= 2
6767 && matches ! ( args[ 0 ] , datafusion:: logical_expr:: ExpressionPlacement :: Column )
68- && args[ 1 ..] . iter ( ) . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
68+ && args[ 1 ..]
69+ . iter ( )
70+ . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
6971 {
7072 datafusion:: logical_expr:: ExpressionPlacement :: MoveTowardsLeafNodes
7173 } else {
Original file line number Diff line number Diff line change @@ -69,7 +69,9 @@ impl ScalarUDFImpl for JsonContains {
6969 // then we can push this UDF down to the leaf nodes.
7070 if args. len ( ) >= 2
7171 && matches ! ( args[ 0 ] , datafusion:: logical_expr:: ExpressionPlacement :: Column )
72- && args[ 1 ..] . iter ( ) . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
72+ && args[ 1 ..]
73+ . iter ( )
74+ . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
7375 {
7476 datafusion:: logical_expr:: ExpressionPlacement :: MoveTowardsLeafNodes
7577 } else {
Original file line number Diff line number Diff line change @@ -71,7 +71,9 @@ impl ScalarUDFImpl for JsonGet {
7171 // then we can push this UDF down to the leaf nodes.
7272 if args. len ( ) >= 2
7373 && matches ! ( args[ 0 ] , datafusion:: logical_expr:: ExpressionPlacement :: Column )
74- && args[ 1 ..] . iter ( ) . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
74+ && args[ 1 ..]
75+ . iter ( )
76+ . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
7577 {
7678 datafusion:: logical_expr:: ExpressionPlacement :: MoveTowardsLeafNodes
7779 } else {
Original file line number Diff line number Diff line change @@ -73,7 +73,9 @@ impl ScalarUDFImpl for JsonGetArray {
7373 // then we can push this UDF down to the leaf nodes.
7474 if args. len ( ) >= 2
7575 && matches ! ( args[ 0 ] , datafusion:: logical_expr:: ExpressionPlacement :: Column )
76- && args[ 1 ..] . iter ( ) . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
76+ && args[ 1 ..]
77+ . iter ( )
78+ . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
7779 {
7880 datafusion:: logical_expr:: ExpressionPlacement :: MoveTowardsLeafNodes
7981 } else {
Original file line number Diff line number Diff line change @@ -64,7 +64,9 @@ impl ScalarUDFImpl for JsonGetBool {
6464 // then we can push this UDF down to the leaf nodes.
6565 if args. len ( ) >= 2
6666 && matches ! ( args[ 0 ] , datafusion:: logical_expr:: ExpressionPlacement :: Column )
67- && args[ 1 ..] . iter ( ) . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
67+ && args[ 1 ..]
68+ . iter ( )
69+ . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
6870 {
6971 datafusion:: logical_expr:: ExpressionPlacement :: MoveTowardsLeafNodes
7072 } else {
Original file line number Diff line number Diff line change @@ -65,7 +65,9 @@ impl ScalarUDFImpl for JsonGetFloat {
6565 // then we can push this UDF down to the leaf nodes.
6666 if args. len ( ) >= 2
6767 && matches ! ( args[ 0 ] , datafusion:: logical_expr:: ExpressionPlacement :: Column )
68- && args[ 1 ..] . iter ( ) . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
68+ && args[ 1 ..]
69+ . iter ( )
70+ . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
6971 {
7072 datafusion:: logical_expr:: ExpressionPlacement :: MoveTowardsLeafNodes
7173 } else {
Original file line number Diff line number Diff line change @@ -65,7 +65,9 @@ impl ScalarUDFImpl for JsonGetInt {
6565 // then we can push this UDF down to the leaf nodes.
6666 if args. len ( ) >= 2
6767 && matches ! ( args[ 0 ] , datafusion:: logical_expr:: ExpressionPlacement :: Column )
68- && args[ 1 ..] . iter ( ) . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
68+ && args[ 1 ..]
69+ . iter ( )
70+ . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
6971 {
7072 datafusion:: logical_expr:: ExpressionPlacement :: MoveTowardsLeafNodes
7173 } else {
Original file line number Diff line number Diff line change @@ -63,7 +63,9 @@ impl ScalarUDFImpl for JsonGetJson {
6363 // then we can push this UDF down to the leaf nodes.
6464 if args. len ( ) >= 2
6565 && matches ! ( args[ 0 ] , datafusion:: logical_expr:: ExpressionPlacement :: Column )
66- && args[ 1 ..] . iter ( ) . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
66+ && args[ 1 ..]
67+ . iter ( )
68+ . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
6769 {
6870 datafusion:: logical_expr:: ExpressionPlacement :: MoveTowardsLeafNodes
6971 } else {
Original file line number Diff line number Diff line change @@ -64,7 +64,9 @@ impl ScalarUDFImpl for JsonGetStr {
6464 // then we can push this UDF down to the leaf nodes.
6565 if args. len ( ) >= 2
6666 && matches ! ( args[ 0 ] , datafusion:: logical_expr:: ExpressionPlacement :: Column )
67- && args[ 1 ..] . iter ( ) . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
67+ && args[ 1 ..]
68+ . iter ( )
69+ . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
6870 {
6971 datafusion:: logical_expr:: ExpressionPlacement :: MoveTowardsLeafNodes
7072 } else {
Original file line number Diff line number Diff line change @@ -65,7 +65,9 @@ impl ScalarUDFImpl for JsonLength {
6565 // then we can push this UDF down to the leaf nodes.
6666 if args. len ( ) >= 2
6767 && matches ! ( args[ 0 ] , datafusion:: logical_expr:: ExpressionPlacement :: Column )
68- && args[ 1 ..] . iter ( ) . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
68+ && args[ 1 ..]
69+ . iter ( )
70+ . all ( |arg| matches ! ( arg, datafusion:: logical_expr:: ExpressionPlacement :: Literal ) )
6971 {
7072 datafusion:: logical_expr:: ExpressionPlacement :: MoveTowardsLeafNodes
7173 } else {
You can’t perform that action at this time.
0 commit comments