Skip to content

Commit

Permalink
Merge branch 'alamb/better_scalar_api' of github.com:alamb/arrow-data…
Browse files Browse the repository at this point in the history
…fusion into alamb/better_scalar_api
  • Loading branch information
alamb committed Dec 20, 2023
2 parents d2fe8e7 + 0cade3f commit 3904129
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions datafusion-examples/examples/advanced_udf.rs
Original file line number Diff line number Diff line change
Expand Up @@ -234,10 +234,10 @@ fn create_context() -> Result<SessionContext> {
let b: ArrayRef = Arc::new(Float64Array::from(vec![1.0, 2.0, 3.0, 4.0]));
let batch = RecordBatch::try_from_iter(vec![("a", a), ("b", b)])?;

// declare a new context. In spark API, this corresponds to a new spark SQLsession
// declare a new context. In Spark API, this corresponds to a new SparkSession
let ctx = SessionContext::new();

// declare a table in memory. In spark API, this corresponds to createDataFrame(...).
// declare a table in memory. In Spark API, this corresponds to createDataFrame(...).
ctx.register_batch("t", batch)?;
Ok(ctx)
}

0 comments on commit 3904129

Please sign in to comment.