Skip to content

Commit

Permalink
update path again, update testing submodule
Browse files Browse the repository at this point in the history
  • Loading branch information
andygrove committed Feb 4, 2019
1 parent 38fa63b commit 6603091
Show file tree
Hide file tree
Showing 6 changed files with 8 additions and 8 deletions.
2 changes: 1 addition & 1 deletion rust/datafusion/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ fn main() {
]));

// register csv file with the execution context
let csv_datasource = CsvDataSource::new("../../testing/csv/uk_cities.csv", schema.clone(), 1024);
let csv_datasource = CsvDataSource::new("../../testing/data/csv/uk_cities.csv", schema.clone(), 1024);
ctx.register_datasource("cities", Rc::new(RefCell::new(csv_datasource)));

// simple projection and selection
Expand Down
2 changes: 1 addition & 1 deletion rust/datafusion/examples/csv_sql.rs
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ fn main() {

// register csv file with the execution context
let csv_datasource =
CsvDataSource::new("../../testing/csv/aggregate_test_100.csv", schema.clone(), 1024);
CsvDataSource::new("../../testing/data/csv/aggregate_test_100.csv", schema.clone(), 1024);
ctx.register_datasource("aggregate_test_100", Rc::new(RefCell::new(csv_datasource)));

// simple projection and selection
Expand Down
6 changes: 3 additions & 3 deletions rust/datafusion/src/execution/aggregate.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1022,7 +1022,7 @@ mod tests {
#[test]
fn min_f64_group_by_string() {
let schema = aggr_test_schema();
let relation = load_csv("../../testing/csv/aggregate_test_100.csv", &schema);
let relation = load_csv("../../testing/data/csv/aggregate_test_100.csv", &schema);
let context = ExecutionContext::new();

let aggr_expr = vec![expression::compile_expr(
Expand Down Expand Up @@ -1057,7 +1057,7 @@ mod tests {
#[test]
fn max_f64_group_by_string() {
let schema = aggr_test_schema();
let relation = load_csv("../../testing/csv/aggregate_test_100.csv", &schema);
let relation = load_csv("../../testing/data/csv/aggregate_test_100.csv", &schema);
let context = ExecutionContext::new();

let aggr_expr = vec![expression::compile_expr(
Expand Down Expand Up @@ -1092,7 +1092,7 @@ mod tests {
#[test]
fn test_min_max_sum_f64_group_by_uint32() {
let schema = aggr_test_schema();
let relation = load_csv("../../testing/csv/aggregate_test_100.csv", &schema);
let relation = load_csv("../../testing/data/csv/aggregate_test_100.csv", &schema);

let context = ExecutionContext::new();

Expand Down
2 changes: 1 addition & 1 deletion rust/datafusion/src/execution/projection.rs
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ mod tests {
Field::new("c12", DataType::Utf8, false),
]));
let ds =
CsvDataSource::new("../../testing/csv/aggregate_test_100.csv", schema.clone(), 1024);
CsvDataSource::new("../../testing/data/csv/aggregate_test_100.csv", schema.clone(), 1024);
let relation = Rc::new(RefCell::new(DataSourceRelation::new(Rc::new(
RefCell::new(ds),
))));
Expand Down
2 changes: 1 addition & 1 deletion rust/datafusion/tests/sql.rs
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ fn register_aggregate_csv(ctx: &mut ExecutionContext) {
register_csv(
ctx,
"aggregate_test_100",
"../../testing/csv/aggregate_test_100.csv",
"../../testing/data/csv/aggregate_test_100.csv",
&schema,
);
}
Expand Down
2 changes: 1 addition & 1 deletion testing

0 comments on commit 6603091

Please sign in to comment.