Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy utilizando Trino para conectarme a PrestoSQL para mi organización de la siguiente manera con python. La autenticación MFA requiere que haga clic en un enlace para autenticarme. Los enlaces suelen tener este aspecto: https://query.organizacion.com:6543/oauth2/token/initiate/b74d83f9e395e4c27d18b Una vez que hago clic en el enlace, se abre una ventana de JupyterLab (captura . . . Read more
Estoy utilizando Spark Structured Streaming (3.1.1) para leer datos de Kafka y utilizar HUDI (0.8.0) como sistema de almacenamiento en S3, particionando los datos por fecha. (no hay problemas con esta sección) Estoy buscando utilizar Trino (355) para poder consultar esos datos. Como requisito previo, ya he colocado el archivo . . . Read more
Hace unos días, envié una consulta usando Presto. Es una consulta muy simple como “select * from table limit 3;”, pero ocurrió un error jdbc. Verifiqué mi controlador en ese momento, estaba utilizando el controlador PrestoDB. El nombre de la clase era ‘com.facebook.presto.jdbc.PrestoDriver’ y lo cambié al controlador PrestoSQL usando . . . Read more
Por ejemplo, tengo un conjunto de datos como el siguiente: tiempo acción 03:00:00 bloquear 04:00:00 desbloquear 05:00:00 bloquear 06:00:00 desbloquear 07:00:00 desbloquear 08:00:00 bloquear Ahora, para cada fila, quiero obtener el último tiempo en el que la columna acción sea igual a “bloquear” antes del tiempo de la fila actual. . . . Read more
He creado una UDF personalizada que está registrada, pero cuando intento ejecutar select do_protect('abc@test.com','Test_EMAIL'); obtengo el siguiente error: io.trino.spi.TrinoException: La implementación exacta de do_protect no coincide con los tipos de Java esperados Aquí está mi UDF de Trino. Quiero pasar dos parámetros de tipo cadena (VARCHAR). @ScalarFunction(“do_protect”) @Description(“Devuelve una cadena . . . Read more