comphead commented on code in PR #13939:
URL: https://github.com/apache/datafusion/pull/13939#discussion_r1899183249
##########
datafusion-examples/examples/dataframe.rs:
##########
@@ -206,3 +215,38 @@ async fn write_out(ctx: &SessionContext) ->
std::result::Result<(), DataFusionEr
Ok(())
}
+
+/// This example demonstrates how to use the to_date series
+/// of functions in the DataFrame API as well as via sql.
+async fn query_to_date() -> Result<()> {
+ // define a schema.
+ let schema = Arc::new(Schema::new(vec![Field::new("a", DataType::Utf8,
false)]));
+
+ // define data.
+ let batch = RecordBatch::try_new(
+ schema,
+ vec![Arc::new(StringArray::from(vec![
+ "2020-09-08T13:42:29Z",
+ "2020-09-08T13:42:29.190855-05:00",
+ "2020-08-09 12:13:29",
+ "2020-01-02",
+ ]))],
+ )?;
+
+ // declare a new context. In spark API, this corresponds to a new spark
SQLsession
+ let ctx = SessionContext::new();
+
+ // declare a table in memory. In spark API, this corresponds to
createDataFrame(...).
+ ctx.register_batch("t", batch)?;
+ let df = ctx.table("t").await?;
+
+ // use to_date function to convert col 'a' to timestamp type using the
default parsing
+ let df = df.with_column("a", to_date(vec![col("a")]))?;
+
+ let df = df.select_columns(&["a"])?;
+
+ // print the results
+ df.show().await?;
Review Comment:
just a nit: would be `assert` better here so the user can understand the
output without running the example?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: github-unsubscr...@datafusion.apache.org
For additional commands, e-mail: github-h...@datafusion.apache.org
