Resultados de la búsqueda a petición "hive"
Exportar como csv en beeline hive
Estoy tratando de exportar mi tabla de colmena como un csv en beeline hive. Cuando ejecuto el comando!sql select * from database1 > /user/bob/output.csv me da error de sintaxis. Me he conectado con éxito a la base de datos en este momento usando ...
¿Cómo crear SparkSession con soporte de Hive (falla con "No se encuentran las clases de Hive")?
Recibo este error cuando intento ejecutar este código. import org.apache.spark.sql.Dataset; import org.apache.spark.sql.Row; import org.apache.spark.sql.SparkSession; public class App { public static void main(String[] args) throws Exception { ...
¿Se pueden cargar variables hiveconf desde un archivo? (Separado del archivo HiveQL)
A menudo tengo un gran bloque de HiveQL que quiero ejecutar varias veces con diferentes configuraciones para algunas variables. Un ejemplo simple sería: set mindate='2015-01-01 00:00:00' set maxdate='2015-04-01 00:00:00' select * from my_table ...
Cómo conectarse al servidor de colmena remoto desde spark
Estoy ejecutando spark localmente y quiero acceder a las tablas de Hive, que se encuentran en el clúster de Hadoop remoto. Puedo acceder a las tablas de la colmena iniciando beeline en SPARK_HOME [ml@master spark-2.0.0]$./bin/beeline Beeline ...
Spark 2.0: "Tabla o vista no encontrada" al consultar Hive [cerrado]
Al consultar Hive a través despark-shell 2.0: spark.sql("SELECT * FROM schemaname.tablename")Lanza un error: 16/08/13 09:24:17 INFO execution.SparkSqlParser: Parsing command: SELECT * FROM schemaname.tablename ...
Use más de una collect_list en una consulta en Spark SQL
Tengo el siguiente marco de datosdata: root |-- userId: string |-- product: string |-- rating: doubley la siguiente consulta: val result = sqlContext.sql("select userId, collect_list(product), collect_list(rating) from data group by userId")Mi ...
El directorio de scratch raíz: / tmp / hive en HDFS debe poder escribirse. Los permisos actuales son: -wx ------
He cambiado el permiso usando el comando hdfs. Todavía muestra el mismo error. El directorio de scratch raíz: / tmp / hive en HDFS debe poder escribirse. Los permisos actuales son: -wx ------ Programa Java que estoy ejecutando. import ...
Excepción al usar la vista lateral en Hive
Estoy usando el siguiente código para analizar datos xml en Hive. En mis datos xml, se repiten algunas etiquetas, por lo que estoy usando el tarro brickhouse y la vista lateral para analizar las etiquetas y colocarlas en las tablas de Hive. Pero ...
Cómo implementar el incremento automático en spark SQL (PySpark)
Necesito implementar una columna de incremento automático en mi tabla spark sql, ¿cómo podría hacer eso? Amablemente guíame. estoy usando pyspark 2.0 Gracias kalyan
¿Cómo seleccionar las filas en orden original en Hive?
Quiero seleccionar filas de mytable en filas originales con números definidos. Como sabemos, la palabra clave 'límite' seleccionará aleatoriamente filas. Las filas en mytable están en orden. Solo quiero seleccionarlos en su orden original. Por ...