Skip to content

Commit

Permalink
revert some changes
Browse files Browse the repository at this point in the history
  • Loading branch information
andygrove committed Jan 22, 2025
1 parent 16c4287 commit 79887f9
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 10 deletions.
3 changes: 0 additions & 3 deletions native/core/src/parquet/schema_adapter.rs
Original file line number Diff line number Diff line change
Expand Up @@ -343,9 +343,6 @@ fn cast_supported(from_type: &DataType, to_type: &DataType, options: &SparkParqu
}
true
}
(List(from_element), List(to_element)) => {
cast_supported(from_element.data_type(), to_element.data_type(), options)
}
_ => false,
}
}
Expand Down
5 changes: 0 additions & 5 deletions native/spark-expr/src/conversion_funcs/cast.rs
Original file line number Diff line number Diff line change
Expand Up @@ -162,8 +162,6 @@ pub fn cast_supported(
) -> bool {
use DataType::*;

println!("cast_supported: {from_type} -> {to_type}");

let from_type = if let Dictionary(_, dt) = from_type {
dt
} else {
Expand Down Expand Up @@ -202,9 +200,6 @@ pub fn cast_supported(
.iter()
.zip(to_fields.iter())
.all(|(a, b)| cast_supported(a.data_type(), b.data_type(), options)),
(List(from_type), List(to_type)) => {
cast_supported(from_type.data_type(), to_type.data_type(), options)
}
_ => false,
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1463,8 +1463,6 @@ object CometSparkSessionExtensions extends Logging {
* The node with information (if any) attached
*/
def withInfos[T <: TreeNode[_]](node: T, info: Set[String], exprs: T*): T = {
// scalastyle:off println
println(s"withInfo ${info.mkString}")
val existingNodeInfos = node.getTagValue(CometExplainInfo.EXTENSION_INFO)
val newNodeInfo = (existingNodeInfos ++ exprs
.flatMap(_.getTagValue(CometExplainInfo.EXTENSION_INFO))).flatten.toSet
Expand Down

0 comments on commit 79887f9

Please sign in to comment.