Skip to content

Commit

Permalink
Revert test changes
Browse files Browse the repository at this point in the history
  • Loading branch information
alamb authored Feb 29, 2024
1 parent d83cef5 commit dd9baa0
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions datafusion/core/tests/parquet/row_group_pruning.rs
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ impl RowGroupPruningTest {
async fn prune_timestamps_nanos() {
RowGroupPruningTest::new()
.with_scenario(Scenario::Timestamps)
.with_query("SELECT * FROM t where nanos < arrow_cast('2020-01-02T01:01:11', 'Timestamp(Nanosecond, None)')")
.with_query("SELECT * FROM t where nanos < to_timestamp('2020-01-02 01:01:11Z')")
.with_expected_errors(Some(0))
.with_pruned_by_stats(Some(1))
.with_pruned_by_bloom_filter(Some(0))
Expand All @@ -126,7 +126,7 @@ async fn prune_timestamps_micros() {
RowGroupPruningTest::new()
.with_scenario(Scenario::Timestamps)
.with_query(
"SELECT * FROM t where micros < arrow_cast('2020-01-02T01:01:11', 'Timestamp(Microsecond, None)')",
"SELECT * FROM t where micros < to_timestamp_micros('2020-01-02 01:01:11Z')",
)
.with_expected_errors(Some(0))
.with_pruned_by_stats(Some(1))
Expand All @@ -141,7 +141,7 @@ async fn prune_timestamps_millis() {
RowGroupPruningTest::new()
.with_scenario(Scenario::Timestamps)
.with_query(
"SELECT * FROM t where millis < arrow_cast('2020-01-02T01:01:11', 'Timestamp(Millisecond, None)')",
"SELECT * FROM t where micros < to_timestamp_millis('2020-01-02 01:01:11Z')",
)
.with_expected_errors(Some(0))
.with_pruned_by_stats(Some(1))
Expand All @@ -156,7 +156,7 @@ async fn prune_timestamps_seconds() {
RowGroupPruningTest::new()
.with_scenario(Scenario::Timestamps)
.with_query(
"SELECT * FROM t where seconds < arrow_cast('2020-01-02T01:01:11', 'Timestamp(Second, None)')",
"SELECT * FROM t where seconds < to_timestamp_seconds('2020-01-02 01:01:11Z')",
)
.with_expected_errors(Some(0))
.with_pruned_by_stats(Some(1))
Expand Down Expand Up @@ -209,7 +209,7 @@ async fn prune_date64() {
async fn prune_disabled() {
RowGroupPruningTest::new()
.with_scenario(Scenario::Timestamps)
.with_query("SELECT * FROM t where nanos < arrow_cast('2020-01-02T01:01:11', 'Timestamp(Nanosecond, None)')")
.with_query("SELECT * FROM t where nanos < to_timestamp('2020-01-02 01:01:11Z')")
.with_expected_errors(Some(0))
.with_pruned_by_stats(Some(1))
.with_pruned_by_bloom_filter(Some(0))
Expand All @@ -218,7 +218,7 @@ async fn prune_disabled() {
.await;

// test without pruning
let query = "SELECT * FROM t where nanos < arrow_cast('2020-01-02T01:01:11', 'Timestamp(Nanosecond, None)')";
let query = "SELECT * FROM t where nanos < to_timestamp('2020-01-02 01:01:11Z')";
let expected_rows = 10;
let config = SessionConfig::new().with_parquet_pruning(false);

Expand Down

0 comments on commit dd9baa0

Please sign in to comment.