Cómo enviar trabajos de Spark de jar por lotes por livy Programmatic API

Quiero enviar trabajos de Spark de jarra por lotes usando livy API programática, como usar lotes de API de descanso, tengo los datos json

{
    "className": "org.apache.spark.examples.SparkPi",
    "queue": "default",
    "name": "SparkPi by Livy",
    "proxyUser": "hadoop",
    "executorMemory": "5g",
    "args": [2000],
    "file": "hdfs://host:port/resources/spark-examples_2.11-2.1.1.jar"
}

pero no puedo encontrar ningún documento sobre esto, ¿es esto posible? ¿cómo?

Respuesta 1

Acabo de programar un programa que tiene un JFrame que contiene una matriz de JLabels. La matriz obtiene la posición de los JLabel individuales asignados por un bucle for: for (int i = 0; i <label_entries.length; i ++) {...

Necesito detectar si un lector está vacío (no generará datos), antes de pasar el lector a alguna función externa. Lo mejor que puedo encontrar es envolver mi Reader en un BufferedReader que garantiza ...

Estoy tratando de usar un grupo de subprocesos fijos en Java 8 que funciona perfecto siempre que permanezca dentro de la misma función. Una vez que trato de compartir el ejecutor como parámetro, nunca se ejecuta en paralelo. Esto funciona ...

Tengo un Edittext, donde quiero permitir solo números y números decimales (máximo 2 decimales después del separador, por ejemplo, 125.50). Implementé un filtro para esto: final EditText field1 = (EditText) ...