We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 179c489 commit acec3ccCopy full SHA for acec3cc
datafusion-postgres/src/pg_catalog.rs
@@ -1788,11 +1788,14 @@ pub fn create_pg_get_userbyid_udf() -> ScalarUDF {
1788
// Define the function implementation
1789
let func = move |args: &[ColumnarValue]| {
1790
let args = ColumnarValue::values_to_arrays(args)?;
1791
- let _input = &args[0]; // User OID, but we'll ignore for now
+ let input = &args[0]; // User OID, but we'll ignore for now
1792
1793
// Create a UTF8 array with default user name
1794
let mut builder = StringBuilder::new();
1795
- builder.append_value("postgres");
+ for _ in 0..input.len() {
1796
+ builder.append_value("postgres");
1797
+ }
1798
+
1799
let array: ArrayRef = Arc::new(builder.finish());
1800
1801
Ok(ColumnarValue::Array(array))
0 commit comments