Skip to content

Commit a0097a2

Browse files
committed
chore: update for deprecated APIs
1 parent 88d5341 commit a0097a2

File tree

2 files changed

+7
-11
lines changed

2 files changed

+7
-11
lines changed

datafusion/core/src/datasource/physical_plan/arrow_file.rs

+3-8
Original file line numberDiff line numberDiff line change
@@ -309,10 +309,8 @@ impl FileOpener for ArrowOpener {
309309
for (dict_block, dict_result) in
310310
footer.dictionaries().iter().flatten().zip(dict_results)
311311
{
312-
decoder.read_dictionary(
313-
dict_block,
314-
&Buffer::from_bytes(dict_result.into()),
315-
)?;
312+
decoder
313+
.read_dictionary(dict_block, &Buffer::from(dict_result))?;
316314
}
317315

318316
// filter recordbatches according to range
@@ -348,10 +346,7 @@ impl FileOpener for ArrowOpener {
348346
.zip(recordbatch_results)
349347
.filter_map(move |(block, data)| {
350348
decoder
351-
.read_record_batch(
352-
&block,
353-
&Buffer::from_bytes(data.into()),
354-
)
349+
.read_record_batch(&block, &Buffer::from(data))
355350
.transpose()
356351
}),
357352
)

datafusion/optimizer/src/unwrap_cast_in_comparison.rs

+4-3
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,8 @@ use crate::{OptimizerConfig, OptimizerRule};
2626

2727
use crate::utils::NamePreserver;
2828
use arrow::datatypes::{
29-
DataType, TimeUnit, MAX_DECIMAL_FOR_EACH_PRECISION, MIN_DECIMAL_FOR_EACH_PRECISION,
29+
DataType, TimeUnit, MAX_DECIMAL128_FOR_EACH_PRECISION,
30+
MIN_DECIMAL128_FOR_EACH_PRECISION,
3031
};
3132
use arrow::temporal_conversions::{MICROSECONDS, MILLISECONDS, NANOSECONDS};
3233
use datafusion_common::tree_node::{Transformed, TreeNode, TreeNodeRewriter};
@@ -369,8 +370,8 @@ fn try_cast_numeric_literal(
369370
// Different precision for decimal128 can store different range of value.
370371
// For example, the precision is 3, the max of value is `999` and the min
371372
// value is `-999`
372-
MIN_DECIMAL_FOR_EACH_PRECISION[*precision as usize - 1],
373-
MAX_DECIMAL_FOR_EACH_PRECISION[*precision as usize - 1],
373+
MIN_DECIMAL128_FOR_EACH_PRECISION[*precision as usize],
374+
MAX_DECIMAL128_FOR_EACH_PRECISION[*precision as usize],
374375
),
375376
_ => return None,
376377
};

0 commit comments

Comments
 (0)