Ilum API (1.5.3)

Scarica la specifica OpenAPI:Scaricare

Ilum API

Gruppo

Restituisce una pagina di gruppi esistenti

quesito Parametri

groupStates	Matrice di Stringhe (groupState) Elementi Enumerazione: "ATTIVO" "ARCHIVIATO" Elenco degli stati del gruppo da applicare per il filtro
groupKinds	Matrice di Stringhe (groupKind) Elementi Enumerazione: "LAVORO" "CODICE" Elenco dei tipi di gruppo da applicare per il filtro
jobStates	Matrice di Stringhe (jobState) Default: "SUBMITTED&jobStates=STARTING&jobStates=READY&jobStates=BUSY" Elementi Enumerazione: "INVIATO" "PARTENZA" "PRONTI" "OCCUPATO" "FALLITO" "FINITO" "CANCELED" "SCONOSCIUTA" Elenco degli stati del processo da applicare per il filtro
clusterNames	Matrice di Stringhe Elenco dei nomi dei cluster da applicare per il filtro
Tag	corda Un elenco separato da punto e virgola di tag da applicare per il filtro. Modello: key1=valore1; key2=valore2
ricerca	corda La parola da applicare per il filtraggio
pagina	numero intero Default: 0 Il numero di pagine da restituire
grandezza	numero intero Default: 10 La dimensione della pagina da restituire
sorta	Matrice di Stringhe Esempio: sort=nome,asc Le regole di ordinamento da applicare definiscono l'ordine di paging

Risposte

Esempi di risposta

200

Tipo di contenuto

Applicazione/JSON

{"pagina": {"numero": 0,
"Taglia": 0,
"offset": 0,
"impaginato": vero
},
"ordina": ["corda"
],
"totalElements": 0,
"totalPages": 0,
"Primo": vero,
"ultimo": vero,
"vuoto": vero,
"contenuto": [{"id": "corda",
"nome": "corda",
"Descrizione": "corda",
"gentile": "corda",
"tag": "corda",
"linguaggio": "corda",
"clusterName": "corda",
"Stato": "corda",
"scala": 0,
"jobConfig": { },
"pyRequirements": "corda",
"packages": "corda",
"createdTime": 0,
"Tempo archiviato": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
},
"autoPause": vero,
"posti di lavoro": [{"jobId": "corda",
"groupId": "corda",
"scheduleId": "corda",
"nomelavoro": "corda",
"jobType": "corda",
"tag": "corda",
"linguaggio": "corda",
"classe professionale": "corda",
"clusterName": "corda",
"jobConfig": "corda",
"args": ["corda"
],
"pyRequirements": "corda",
"packages": "corda",
"appId": "corda",
"Stato": "corda",
"errore": "corda",
"submitTime": 0,
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"attempt": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
}
}
]
}
]
}

Crea un gruppo di processi Spark interattivi

Schema del corpo della richiesta: multipart/form-data
Obbligatorio

nome Obbligatorio	corda
descrizione	corda
gentile	corda Default: "LAVORO" Enumerazione: "LAVORO" "CODICE"
Tag	corda Default: "chiave=valore; key2=valore2" Un elenco di tag separati da punto e virgola. La chiave e il valore del parametro devono essere separati da un segno di uguale.
Lingua	corda Default: "SCALA" Enumerazione: "SCALA" "PITONE"
clusterName Obbligatorio	corda Default: "predefinito"
Vasi	Matrice di Stringhe <binario> [ articoli <binario > ]
ﬁle	Matrice di Stringhe <binario> [ articoli <binario > ]
pyFiles	Matrice di Stringhe <binario> [ articoli <binario > ]
jobConfig	corda Default: "spark.key=valore; spark.key2=valore2" Elenco separato da punto e virgola dei parametri Spark da applicare per il processo Spark. La chiave e il valore del parametro devono essere separati da un segno di uguale.
pyRequisiti	corda Un elenco separato da punto e virgola dei requisiti di Python. Il nome e la versione del pacchetto (se specificata) devono essere separati da un doppio segno di uguale.
packages	corda Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version.
scala	corda Default: 1 Numero intero di processi Spark da avviare all'interno di questo gruppo
executors	corda number of executors to run
driverCores	corda Number of cores to use for the driver process.
executorCores	corda The number of cores to use on each executor.
driverMemory	corda Amount of memory to use for the driver process, i.e. where SparkContext is initialized, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g).
executorMemory	corda Amount of memory to use per executor process, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g).
dynamicAllocation	corda Default: "falso" Whether to use dynamic resource allocation, which scales the number of executors registered with this application up and down based on the workload.
initialExecutors	corda Initial number of executors to run if dynamic allocation is enabled.
minExecutors	corda Upper bound for the number of executors if dynamic allocation is enabled.
maxExecutors	corda Lower bound for the number of executors if dynamic allocation is enabled.
autoPause	corda Default: "falso" Boolean flag to enable auto-pause feature

Risposte

Esempi di risposta

200
402
404
409

Tipo di contenuto

Applicazione/JSON

{"groupId": "corda"
}

Restituisce un gruppo trovato in base al suo id

sentiero Parametri

groupId

Obbligatorio

corda

L'identificatore univoco di un gruppo

Risposte

Esempi di risposta

200
404

Tipo di contenuto

Applicazione/JSON

{"id": "corda",
"nome": "corda",
"Descrizione": "corda",
"gentile": "corda",
"tag": "corda",
"linguaggio": "corda",
"clusterName": "corda",
"Stato": "corda",
"scala": 0,
"jobConfig": { },
"pyRequirements": "corda",
"packages": "corda",
"createdTime": 0,
"Tempo archiviato": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
},
"autoPause": vero,
"posti di lavoro": [{"jobId": "corda",
"groupId": "corda",
"scheduleId": "corda",
"nomelavoro": "corda",
"jobType": "corda",
"tag": "corda",
"linguaggio": "corda",
"classe professionale": "corda",
"clusterName": "corda",
"jobConfig": "corda",
"args": ["corda"
],
"pyRequirements": "corda",
"packages": "corda",
"appId": "corda",
"Stato": "corda",
"errore": "corda",
"submitTime": 0,
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"attempt": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
}
}
]
}

Elimina un gruppo in base al suo id

sentiero Parametri

groupId

Obbligatorio

corda

L'identificatore univoco di un gruppo

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Updates a group by its id

sentiero Parametri

groupId

Obbligatorio

corda

L'identificatore univoco di un gruppo

Schema del corpo della richiesta: multipart/form-data
Obbligatorio

descrizione	corda
Tag	corda Un elenco di tag separati da punto e virgola. La chiave e il valore del parametro devono essere separati da un segno di uguale.
jobConfig	corda Elenco separato da punto e virgola dei parametri Spark da applicare per il processo Spark. La chiave e il valore del parametro devono essere separati da un segno di uguale.
pyRequisiti	corda Un elenco separato da punto e virgola dei requisiti di Python. Il nome e la versione del pacchetto (se specificata) devono essere separati da un doppio segno di uguale.
packages	corda Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version.
scala	corda Numero intero di processi Spark da avviare all'interno di questo gruppo
executors	corda number of executors to run
driverCores	corda Number of cores to use for the driver process.
executorCores	corda The number of cores to use on each executor.
driverMemory	corda Amount of memory to use for the driver process, i.e. where SparkContext is initialized, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g).
executorMemory	corda Amount of memory to use per executor process, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g).
dynamicAllocation	corda Default: "falso" Whether to use dynamic resource allocation, which scales the number of executors registered with this application up and down based on the workload.
initialExecutors	corda Initial number of executors to run if dynamic allocation is enabled.
minExecutors	corda Upper bound for the number of executors if dynamic allocation is enabled.
maxExecutors	corda Lower bound for the number of executors if dynamic allocation is enabled.
autoPause	corda Default: "falso" Boolean flag to enable auto-pause feature

Risposte

Esempi di risposta

402
404
409

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Esegue un processo Spark interattivo all'interno del gruppo scelto

Esegue un processo Spark interattivo all'interno del gruppo scelto e attende il completamento dell'istanza del processo. Il risultato viene restituito come risposta.

sentiero Parametri

groupId

Obbligatorio

corda

L'identificatore univoco di un gruppo

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

digitare Obbligatorio	corda Default: "interactive_job_execute" interactive_job_execute
classe di lavoro Obbligatorio	corda
Obbligatorio	oggetto

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

Esempio

interactive_job_execute

{"tipo": "interactive_job_execute",
"classe professionale": "corda",
"jobConfig": { }
}

Esempi di risposta

200
402
404
409

Tipo di contenuto

Applicazione/JSON

{"jobInstanceId": "corda",
"jobId": "corda",
"groupId": "corda",
"startTime": 0,
"endTime": 0,
"classe professionale": "corda",
"jobConfig": { },
"risultato": "corda",
"errore": {"messaggio": "corda",
"stackTrace": "corda"
}
}

Restituisce una pagina di risultati dell'istanza del processo di gruppo esistente

sentiero Parametri

groupId

Obbligatorio

corda

L'identificatore univoco di un gruppo

quesito Parametri

ricerca	corda La parola da applicare per il filtraggio
pagina	numero intero Default: 0 Il numero di pagine da restituire
grandezza	numero intero Default: 10 La dimensione della pagina da restituire
sorta	Matrice di Stringhe Esempio: sort=nome,asc Le regole di ordinamento da applicare definiscono l'ordine di paging

Risposte

Esempi di risposta

200

Tipo di contenuto

Applicazione/JSON

{"pagina": {"numero": 0,
"Taglia": 0,
"offset": 0,
"impaginato": vero
},
"ordina": ["corda"
],
"totalElements": 0,
"totalPages": 0,
"Primo": vero,
"ultimo": vero,
"vuoto": vero,
"contenuto": [{"jobInstanceId": "corda",
"jobId": "corda",
"groupId": "corda",
"startTime": 0,
"endTime": 0,
"classe professionale": "corda",
"jobConfig": { },
"risultato": "corda",
"errore": {"messaggio": "corda",
"stackTrace": "corda"
}
}
]
}

Invia un processo Spark interattivo all'interno del gruppo scelto

Invia un processo Spark interattivo all'interno del gruppo scelto. Non attende il completamento del lavoro. Restituisce invece l'ID istanza del processo creato. Il risultato può essere recuperato da un risultato dell'istanza del processo Aggiorna l'abbonamento.

sentiero Parametri

groupId

Obbligatorio

corda

L'identificatore univoco di un gruppo

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

digitare Obbligatorio	corda Default: "interactive_job_execute" interactive_job_execute
classe di lavoro Obbligatorio	corda
Obbligatorio	oggetto

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

Esempio

interactive_job_execute

{"tipo": "interactive_job_execute",
"classe professionale": "corda",
"jobConfig": { }
}

Esempi di risposta

200
402
404
409

Tipo di contenuto

Applicazione/JSON

{"jobInstanceId": "corda"
}

Modifica il numero di processi Spark interattivi usati dal gruppo scelto

sentiero Parametri

groupId Obbligatorio	corda L'identificatore univoco di un gruppo
scala Obbligatorio	numero intero Numero di istanze per ridimensionare il processo Spark interattivo all'interno del gruppo

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Restarts a chosen group

sentiero Parametri

groupId

Obbligatorio

corda

L'identificatore univoco di un gruppo

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Pauses a chosen group

sentiero Parametri

groupId

Obbligatorio

corda

L'identificatore univoco di un gruppo

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Resumes a chosen group

sentiero Parametri

groupId

Obbligatorio

corda

L'identificatore univoco di un gruppo

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Arresta un gruppo scelto e lo mette in stato ARCHIVIATO

sentiero Parametri

groupId

Obbligatorio

corda

L'identificatore univoco di un gruppo

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Restituisce un flusso di modifiche interattive ai risultati del processo Spark

quesito Parametri

jobIds	Matrice di Stringhe L'elenco degli ID processo da applicare per il filtro
groupIds	Matrice di Stringhe L'elenco degli ID gruppo da applicare per il filtro
clusterNames	Matrice di Stringhe Elenco dei nomi dei cluster da applicare per il filtro
groupNames	Matrice di Stringhe Elenco dei nomi dei gruppi da applicare per il filtro
Tag	corda Un elenco separato da punto e virgola di tag da applicare per il filtro. Modello: key1=valore1; key2=valore2

Risposte

Restituisce un gruppo trovato in base al nome

sentiero Parametri

groupName

Obbligatorio

corda

Il nome univoco di un gruppo

Risposte

Esempi di risposta

200
404

Tipo di contenuto

Applicazione/JSON

{"id": "corda",
"nome": "corda",
"Descrizione": "corda",
"gentile": "corda",
"tag": "corda",
"linguaggio": "corda",
"clusterName": "corda",
"Stato": "corda",
"scala": 0,
"jobConfig": { },
"pyRequirements": "corda",
"packages": "corda",
"createdTime": 0,
"Tempo archiviato": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
},
"autoPause": vero,
"posti di lavoro": [{"jobId": "corda",
"groupId": "corda",
"scheduleId": "corda",
"nomelavoro": "corda",
"jobType": "corda",
"tag": "corda",
"linguaggio": "corda",
"classe professionale": "corda",
"clusterName": "corda",
"jobConfig": "corda",
"args": ["corda"
],
"pyRequirements": "corda",
"packages": "corda",
"appId": "corda",
"Stato": "corda",
"errore": "corda",
"submitTime": 0,
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"attempt": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
}
}
]
}

Programma

Returns a page of existing schedules

quesito Parametri

scheduleStates	Matrice di Stringhe (scheduleState) Default: "ENABLED" Elementi Enumerazione: "ENABLED" "DISABLED" "PAUSED" The list of schedule states to apply for filtering
scheduleCrons	Matrice di Stringhe The list of schedule crons to apply for filtering
jobStates	Matrice di Stringhe (jobState) Default: "SUBMITTED&jobStates=STARTING&jobStates=READY&jobStates=BUSY" Elementi Enumerazione: "INVIATO" "PARTENZA" "PRONTI" "OCCUPATO" "FALLITO" "FINITO" "CANCELED" "SCONOSCIUTA" Elenco degli stati del processo da applicare per il filtro
clusterNames	Matrice di Stringhe Elenco dei nomi dei cluster da applicare per il filtro
Tag	corda Un elenco separato da punto e virgola di tag da applicare per il filtro. Modello: key1=valore1; key2=valore2
ricerca	corda La parola da applicare per il filtraggio
pagina	numero intero Default: 0 Il numero di pagine da restituire
grandezza	numero intero Default: 10 La dimensione della pagina da restituire
sorta	Matrice di Stringhe Esempio: sort=nome,asc Le regole di ordinamento da applicare definiscono l'ordine di paging

Risposte

Esempi di risposta

200

Tipo di contenuto

Applicazione/JSON

{"pagina": {"numero": 0,
"Taglia": 0,
"offset": 0,
"impaginato": vero
},
"ordina": ["corda"
],
"totalElements": 0,
"totalPages": 0,
"Primo": vero,
"ultimo": vero,
"vuoto": vero,
"contenuto": [{"id": "corda",
"nome": "corda",
"Descrizione": "corda",
"cron": "corda",
"tag": "corda",
"linguaggio": "corda",
"clusterName": "corda",
"jobConfig": { },
"pyRequirements": "corda",
"packages": "corda",
"Stato": "corda",
"classe professionale": "corda",
"args": ["corda"
],
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"createdTime": 0,
"disabledTime": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
},
"posti di lavoro": [{"jobId": "corda",
"groupId": "corda",
"scheduleId": "corda",
"nomelavoro": "corda",
"jobType": "corda",
"tag": "corda",
"linguaggio": "corda",
"classe professionale": "corda",
"clusterName": "corda",
"jobConfig": "corda",
"args": ["corda"
],
"pyRequirements": "corda",
"packages": "corda",
"appId": "corda",
"Stato": "corda",
"errore": "corda",
"submitTime": 0,
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"attempt": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
}
}
]
}
]
}

Creates a schedule of single Spark jobs

Schema del corpo della richiesta: multipart/form-data
Obbligatorio

nome Obbligatorio	corda
descrizione	corda
cron Obbligatorio	corda
Tag	corda Default: "chiave=valore; key2=valore2" Un elenco di tag separati da punto e virgola. La chiave e il valore del parametro devono essere separati da un segno di uguale.
Lingua	corda Default: "SCALA" Enumerazione: "SCALA" "PITONE"
clusterName Obbligatorio	corda Default: "predefinito"
Vasi	Matrice di Stringhe <binario> [ articoli <binario > ]
ﬁle	Matrice di Stringhe <binario> [ articoli <binario > ]
pyFiles	Matrice di Stringhe <binario> [ articoli <binario > ]
jobConfig	corda Default: "spark.key=valore; spark.key2=valore2" Elenco separato da punto e virgola dei parametri Spark da applicare per il processo Spark. La chiave e il valore del parametro devono essere separati da un segno di uguale.
classe di lavoro Obbligatorio	corda
argomenti	corda list of spark arguments to be applied for the Spark job.
pyRequisiti	corda Un elenco separato da punto e virgola dei requisiti di Python. Il nome e la versione del pacchetto (se specificata) devono essere separati da un doppio segno di uguale.
packages	corda Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version.
startTime	corda The time when the schedule will start in epoch milliseconds (e.g. 1727733600000, which means 01.10.2024). If not provided, the schedule will start immediately.
endTime	corda The time when the schedule will be suspended in epoch milliseconds (e.g. 1727820000000, which means 02.10.2024). If not provided, the schedule will create jobs until schedule disabling.
maxRetries	corda Default: 0 Max number of retries to be performed if the job fails
executors	corda number of executors to run
driverCores	corda Number of cores to use for the driver process.
executorCores	corda The number of cores to use on each executor.
driverMemory	corda Amount of memory to use for the driver process, i.e. where SparkContext is initialized, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g).
executorMemory	corda Amount of memory to use per executor process, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g).
dynamicAllocation	corda Default: "falso" Whether to use dynamic resource allocation, which scales the number of executors registered with this application up and down based on the workload.
initialExecutors	corda Initial number of executors to run if dynamic allocation is enabled.
minExecutors	corda Upper bound for the number of executors if dynamic allocation is enabled.
maxExecutors	corda Lower bound for the number of executors if dynamic allocation is enabled.

Risposte

Esempi di risposta

200
402
404
409

Tipo di contenuto

Applicazione/JSON

{"scheduleId": "corda"
}

Returns a schedule found by its id

sentiero Parametri

scheduleId

Obbligatorio

corda

The unique identifier of a schedule

Risposte

Esempi di risposta

200
404

Tipo di contenuto

Applicazione/JSON

{"id": "corda",
"nome": "corda",
"Descrizione": "corda",
"cron": "corda",
"tag": "corda",
"linguaggio": "corda",
"clusterName": "corda",
"jobConfig": { },
"pyRequirements": "corda",
"packages": "corda",
"Stato": "corda",
"classe professionale": "corda",
"args": ["corda"
],
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"createdTime": 0,
"disabledTime": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
},
"posti di lavoro": [{"jobId": "corda",
"groupId": "corda",
"scheduleId": "corda",
"nomelavoro": "corda",
"jobType": "corda",
"tag": "corda",
"linguaggio": "corda",
"classe professionale": "corda",
"clusterName": "corda",
"jobConfig": "corda",
"args": ["corda"
],
"pyRequirements": "corda",
"packages": "corda",
"appId": "corda",
"Stato": "corda",
"errore": "corda",
"submitTime": 0,
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"attempt": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
}
}
]
}

Updates a schedule by its id

sentiero Parametri

scheduleId

Obbligatorio

corda

The unique identifier of a schedule

Schema del corpo della richiesta: multipart/form-data
Obbligatorio

descrizione	corda
Tag	corda Un elenco di tag separati da punto e virgola. La chiave e il valore del parametro devono essere separati da un segno di uguale.
jobConfig	corda Elenco separato da punto e virgola dei parametri Spark da applicare per il processo Spark. La chiave e il valore del parametro devono essere separati da un segno di uguale.
cron	corda Cron expression to be applied for the schedule
argomenti	corda Elenco separato da punto e virgola di argomenti Spark da applicare per il processo Spark.
classe di lavoro	corda
pyRequisiti	corda Un elenco separato da punto e virgola dei requisiti di Python. Il nome e la versione del pacchetto (se specificata) devono essere separati da un doppio segno di uguale.
packages	corda Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version.
startTime	corda The time when the schedule will start in epoch milliseconds (e.g. 1727733600000, which means 01.10.2024). If not provided, the schedule will start immediately.
endTime	corda The time when the schedule will be suspended in epoch milliseconds (e.g. 1727820000000, which means 02.10.2024). If not provided, the schedule will create jobs until schedule disabling.
maxRetries	corda Max number of retries to be performed if the job fails
executors	corda number of executors to run
driverCores	corda Number of cores to use for the driver process.
executorCores	corda The number of cores to use on each executor.
driverMemory	corda Amount of memory to use for the driver process, i.e. where SparkContext is initialized, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g).
executorMemory	corda Amount of memory to use per executor process, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g).
dynamicAllocation	corda Default: "falso" Whether to use dynamic resource allocation, which scales the number of executors registered with this application up and down based on the workload.
initialExecutors	corda Initial number of executors to run if dynamic allocation is enabled.
minExecutors	corda Upper bound for the number of executors if dynamic allocation is enabled.
maxExecutors	corda Lower bound for the number of executors if dynamic allocation is enabled.

Risposte

Esempi di risposta

402
404
409

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Deletes a schedule by its id

sentiero Parametri

scheduleId

Obbligatorio

corda

The unique identifier of a schedule

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Pauses a chosen schedule

sentiero Parametri

scheduleId

Obbligatorio

corda

The unique identifier of a schedule

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Resumes a chosen schedule

sentiero Parametri

scheduleId

Obbligatorio

corda

The unique identifier of a schedule

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Stops a chosen schedule and puts it in DISABLED state

sentiero Parametri

scheduleId

Obbligatorio

corda

The unique identifier of a schedule

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Returns a schedule found by its name

sentiero Parametri

scheduleName

Obbligatorio

corda

The unique name of a schedule

Risposte

Esempi di risposta

200
404

Tipo di contenuto

Applicazione/JSON

{"id": "corda",
"nome": "corda",
"Descrizione": "corda",
"cron": "corda",
"tag": "corda",
"linguaggio": "corda",
"clusterName": "corda",
"jobConfig": { },
"pyRequirements": "corda",
"packages": "corda",
"Stato": "corda",
"classe professionale": "corda",
"args": ["corda"
],
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"createdTime": 0,
"disabledTime": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
},
"posti di lavoro": [{"jobId": "corda",
"groupId": "corda",
"scheduleId": "corda",
"nomelavoro": "corda",
"jobType": "corda",
"tag": "corda",
"linguaggio": "corda",
"classe professionale": "corda",
"clusterName": "corda",
"jobConfig": "corda",
"args": ["corda"
],
"pyRequirements": "corda",
"packages": "corda",
"appId": "corda",
"Stato": "corda",
"errore": "corda",
"submitTime": 0,
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"attempt": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
}
}
]
}

Lavoro

Restituisce una pagina di processi esistenti

quesito Parametri

jobTypes	Matrice di Stringhe (jobType) Elementi Enumerazione: "SINGOLO" "INTERATTIVO" "CONCHIGLIA" Elenco dei tipi di processo da applicare per il filtro
jobStates	Matrice di Stringhe (jobState) Default: "SUBMITTED&jobStates=STARTING&jobStates=READY&jobStates=BUSY" Elementi Enumerazione: "INVIATO" "PARTENZA" "PRONTI" "OCCUPATO" "FALLITO" "FINITO" "CANCELED" "SCONOSCIUTA" Elenco degli stati del processo da applicare per il filtro
clusterNames	Matrice di Stringhe Elenco dei nomi dei cluster da applicare per il filtro
Tag	corda Un elenco separato da punto e virgola di tag da applicare per il filtro. Modello: key1=valore1; key2=valore2
ricerca	corda La parola da applicare per il filtraggio
pagina	numero intero Default: 0 Il numero di pagine da restituire
grandezza	numero intero Default: 10 La dimensione della pagina da restituire
sorta	Matrice di Stringhe Esempio: sort=nome,asc Le regole di ordinamento da applicare definiscono l'ordine di paging

Risposte

Esempi di risposta

200

Tipo di contenuto

Applicazione/JSON

{"pagina": {"numero": 0,
"Taglia": 0,
"offset": 0,
"impaginato": vero
},
"ordina": ["corda"
],
"totalElements": 0,
"totalPages": 0,
"Primo": vero,
"ultimo": vero,
"vuoto": vero,
"contenuto": [{"jobId": "corda",
"groupId": "corda",
"scheduleId": "corda",
"nomelavoro": "corda",
"jobType": "corda",
"tag": "corda",
"linguaggio": "corda",
"classe professionale": "corda",
"clusterName": "corda",
"jobConfig": "corda",
"args": ["corda"
],
"pyRequirements": "corda",
"packages": "corda",
"appId": "corda",
"Stato": "corda",
"errore": "corda",
"submitTime": 0,
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"attempt": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
}
}
]
}

Restituisce un lavoro trovato in base al suo id

sentiero Parametri

jobId

Obbligatorio

corda

L'identificatore univoco di un processo

Risposte

Esempi di risposta

200
404

Tipo di contenuto

Applicazione/JSON

{"jobId": "corda",
"groupId": "corda",
"scheduleId": "corda",
"nomelavoro": "corda",
"jobType": "corda",
"tag": "corda",
"linguaggio": "corda",
"classe professionale": "corda",
"clusterName": "corda",
"jobConfig": "corda",
"args": ["corda"
],
"pyRequirements": "corda",
"packages": "corda",
"appId": "corda",
"Stato": "corda",
"errore": "corda",
"submitTime": 0,
"startTime": 0,
"endTime": 0,
"maxRetries": 0,
"attempt": 0,
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
}
}

Elimina un lavoro trovato in base al suo id

sentiero Parametri

jobId

Obbligatorio

corda

L'identificatore univoco di un processo

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Stops a chosen job and puts it in CANCELED state

sentiero Parametri

jobId

Obbligatorio

corda

L'identificatore univoco di un processo

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Restituisce i log per tutte le risorse del processo

sentiero Parametri

jobId

Obbligatorio

corda

L'identificatore univoco di un processo

quesito Parametri

logSize	numero intero <int64> Default: 100 Numero massimo di righe di log da restituire. Il limite nell'API è impostato a 25000 righe, è possibile modificarlo impostando il parametro ilum.api.job.logs.maxLines nel file di configurazione di ilum-core
Da	numero intero <int64> Default: 0 Offset dall'inizio del log

Risposte

Esempi di risposta

200
404

Tipo di contenuto

Applicazione/JSON

[{"nome": "corda",
"tipo": "corda",
"ruolo": "corda",
"Stato": "corda",
"a partire dal": 0,
"logSize": 0,
"Nome file": "corda",
"registro": ["corda"
]
}
]

Invia un singolo processo Spark

Schema del corpo della richiesta: multipart/form-data
Obbligatorio

nome Obbligatorio	corda
Tag	corda Default: "chiave=valore; key2=valore2" Un elenco di tag separati da punto e virgola. La chiave e il valore del parametro devono essere separati da un segno di uguale.
Lingua	corda Default: "SCALA" Enumerazione: "SCALA" "PITONE"
clusterName Obbligatorio	corda Default: "predefinito"
classe di lavoro	corda
Vasi	Matrice di Stringhe <binario> [ articoli <binario > ]
ﬁle	Matrice di Stringhe <binario> [ articoli <binario > ]
pyFiles	Matrice di Stringhe <binario> [ articoli <binario > ]
jobConfig	corda Default: "spark.key=valore; spark.key2=valore2" Elenco separato da punto e virgola dei parametri Spark da applicare per il processo Spark. La chiave e il valore del parametro devono essere separati da un segno di uguale.
pyRequisiti	corda Un elenco separato da punto e virgola dei requisiti di Python. Il nome e la versione del pacchetto (se specificata) devono essere separati da un doppio segno di uguale.
packages	corda Comma-separated list of Maven coordinates of jars to include on the driver and executor classpaths. The coordinates should be groupId:artifactId:version.
argomenti	corda Elenco separato da punto e virgola di argomenti Spark da applicare per il processo Spark.
maxRetries	corda Default: 0 Max number of retries to be performed if the job fails
executors	corda number of executors to run
driverCores	corda Number of cores to use for the driver process.
executorCores	corda The number of cores to use on each executor.
driverMemory	corda Amount of memory to use for the driver process, i.e. where SparkContext is initialized, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g).
executorMemory	corda Amount of memory to use per executor process, in the same format as JVM memory strings with a size unit suffix ("k", "m", "g" or "t") (e.g. 512m, 2g).
dynamicAllocation	corda Default: "falso" Whether to use dynamic resource allocation, which scales the number of executors registered with this application up and down based on the workload.
initialExecutors	corda Initial number of executors to run if dynamic allocation is enabled.
minExecutors	corda Upper bound for the number of executors if dynamic allocation is enabled.
maxExecutors	corda Lower bound for the number of executors if dynamic allocation is enabled.

Risposte

Esempi di risposta

200
402
404
409

Tipo di contenuto

Applicazione/JSON

{"jobId": "corda"
}

Restituisce un flusso di modifiche al processo Spark

quesito Parametri

jobIds	Matrice di Stringhe L'elenco degli ID processo da applicare per il filtro
groupIds	Matrice di Stringhe L'elenco degli ID gruppo da applicare per il filtro
clusterNames	Matrice di Stringhe Elenco dei nomi dei cluster da applicare per il filtro
Tag	corda Un elenco separato da punto e virgola di tag da applicare per il filtro. Modello: key1=valore1; key2=valore2

Risposte

Grappolo

Crea una definizione di cluster

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

nome Obbligatorio	corda
descrizione	corda
	oggetto
sparkStorage	corda Default: "S3"
metastoreName	corda
	oggetto (memorySettingsCreation)
defaultApplicationConfig	corda
digitare Obbligatorio	corda Default: "K8S" K8S
URL Obbligatorio	corda
caCert	corda
clientCert	corda
Chiave client	corda
clientKeyAlgorithm	corda
clientKeyPassphrase	corda
nome utente	corda
parola d’ordine	corda
	oggetto (clusterResourceQuota)
	oggetto (clusterLimitRange)

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

Esempio

K8S

{"nome": "corda",
"Descrizione": "corda",
"Depositi": {"proprietà1": {"sparkBucket": "corda",
"dataBucket": "corda",
"extraBuckets": ["corda"
],
"tipo": "S3",
"punto finale": "corda",
"region": "us-east-1",
"chiave di accesso": "corda",
"chiave segreta": "corda"
},
"proprietà2": {"sparkBucket": "corda",
"dataBucket": "corda",
"extraBuckets": ["corda"
],
"tipo": "S3",
"punto finale": "corda",
"region": "us-east-1",
"chiave di accesso": "corda",
"chiave segreta": "corda"
}
},
"sparkStorage": "S3",
"metastoreName": "corda",
"memorySettings": {"executors": "corda",
"driverCores": "corda",
"executorCores": "corda",
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": "falso",
"initialExecutors": "corda",
"minExecutors": "corda",
"maxExecutors": "corda"
},
"defaultApplicationConfig": "corda",
"tipo": "K8S",
"url": "corda",
"caCert": "corda",
"clientCert": "corda",
"clientKey": "corda",
"clientKeyAlgorithm": "corda",
"clientKeyPassphrase": "corda",
"nome utente": "corda",
"parola d'ordine": "corda",
"resourceQuota": {"limitsPod": "corda",
"limitsCpu": "corda",
"limitsMemory": "corda",
"requestsCpu": "corda",
"requestsMemory": "corda"
},
"limitRange": {"cpuLimitRange": {"defaultLimit": "corda",
"defaultRequest": "corda",
"minRequest": "corda",
"maxLimit": "corda",
"maxLimitRequestRatio": "corda"
},
"memoryLimitRange": {"defaultLimit": "corda",
"defaultRequest": "corda",
"minRequest": "corda",
"maxLimit": "corda",
"maxLimitRequestRatio": "corda"
}
}
}

Esempi di risposta

200
402
409

Tipo di contenuto

Applicazione/JSON

{"clusterId": "corda"
}

Restituisce una pagina di cluster esistenti

quesito Parametri

ricerca	corda La parola da applicare per il filtraggio
pagina	numero intero Default: 0 Il numero di pagine da restituire
grandezza	numero intero Default: 10 La dimensione della pagina da restituire
sorta	Matrice di Stringhe Esempio: sort=nome,asc Le regole di ordinamento da applicare definiscono l'ordine di paging

Risposte

Esempi di risposta

200

Tipo di contenuto

Applicazione/JSON

{"pagina": {"numero": 0,
"Taglia": 0,
"offset": 0,
"impaginato": vero
},
"ordina": ["corda"
],
"totalElements": 0,
"totalPages": 0,
"Primo": vero,
"ultimo": vero,
"vuoto": vero,
"contenuto": [{"id": "corda",
"nome": "corda",
"Descrizione": "corda",
"maestro di scintille": "corda",
"sparkDeployMode": "corda",
"sparkStorage": "corda",
"metastoreName": "corda",
"Depositi": {"proprietà1": {"sparkBucket": "corda",
"dataBucket": "corda",
"extraBuckets": ["corda"
],
"tipo": "S3",
"punto finale": "corda",
"region": "us-east-1",
"chiave di accesso": "corda",
"chiave segreta": "corda"
},
"proprietà2": {"sparkBucket": "corda",
"dataBucket": "corda",
"extraBuckets": ["corda"
],
"tipo": "S3",
"punto finale": "corda",
"region": "us-east-1",
"chiave di accesso": "corda",
"chiave segreta": "corda"
}
},
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
},
"defaultApplicationConfig": "corda",
"tipo": "K8S",
"url": "corda",
"caCert": "corda",
"clientCert": "corda",
"clientKey": "corda",
"clientKeyAlgorithm": "corda",
"clientKeyPassphrase": "corda",
"nome utente": "corda",
"parola d'ordine": "corda",
"resourceQuota": {"limitsPod": "corda",
"limitsCpu": "corda",
"limitsMemory": "corda",
"requestsCpu": "corda",
"requestsMemory": "corda"
},
"limitRange": {"cpuLimitRange": {"defaultLimit": "corda",
"defaultRequest": "corda",
"minRequest": "corda",
"maxLimit": "corda",
"maxLimitRequestRatio": "corda"
},
"memoryLimitRange": {"defaultLimit": "corda",
"defaultRequest": "corda",
"minRequest": "corda",
"maxLimit": "corda",
"maxLimitRequestRatio": "corda"
}
}
}
]
}

Restituisce un cluster trovato in base al relativo id

sentiero Parametri

clusterId

Obbligatorio

corda

Identificatore univoco di un cluster

Risposte

Esempi di risposta

200
404

Tipo di contenuto

Applicazione/JSON

Esempio

K8S

{"id": "corda",
"nome": "corda",
"Descrizione": "corda",
"maestro di scintille": "corda",
"sparkDeployMode": "corda",
"sparkStorage": "corda",
"metastoreName": "corda",
"Depositi": {"proprietà1": {"sparkBucket": "corda",
"dataBucket": "corda",
"extraBuckets": ["corda"
],
"tipo": "S3",
"punto finale": "corda",
"region": "us-east-1",
"chiave di accesso": "corda",
"chiave segreta": "corda"
},
"proprietà2": {"sparkBucket": "corda",
"dataBucket": "corda",
"extraBuckets": ["corda"
],
"tipo": "S3",
"punto finale": "corda",
"region": "us-east-1",
"chiave di accesso": "corda",
"chiave segreta": "corda"
}
},
"memorySettings": {"executors": 0,
"driverCores": 0,
"executorCores": 0,
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": vero,
"initialExecutors": 0,
"minExecutors": 0,
"maxExecutors": 0
},
"defaultApplicationConfig": "corda",
"tipo": "K8S",
"url": "corda",
"caCert": "corda",
"clientCert": "corda",
"clientKey": "corda",
"clientKeyAlgorithm": "corda",
"clientKeyPassphrase": "corda",
"nome utente": "corda",
"parola d'ordine": "corda",
"resourceQuota": {"limitsPod": "corda",
"limitsCpu": "corda",
"limitsMemory": "corda",
"requestsCpu": "corda",
"requestsMemory": "corda"
},
"limitRange": {"cpuLimitRange": {"defaultLimit": "corda",
"defaultRequest": "corda",
"minRequest": "corda",
"maxLimit": "corda",
"maxLimitRequestRatio": "corda"
},
"memoryLimitRange": {"defaultLimit": "corda",
"defaultRequest": "corda",
"minRequest": "corda",
"maxLimit": "corda",
"maxLimitRequestRatio": "corda"
}
}
}

Updates a cluster by its id

sentiero Parametri

clusterId

Obbligatorio

corda

Identificatore univoco di un cluster

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

nome Obbligatorio	corda
descrizione	corda
	oggetto
sparkStorage	corda Default: "S3"
metastoreName	corda
	oggetto (memorySettingsCreation)
defaultApplicationConfig	corda
digitare Obbligatorio	corda Default: "K8S" K8S
URL Obbligatorio	corda
caCert	corda
clientCert	corda
Chiave client	corda
clientKeyAlgorithm	corda
clientKeyPassphrase	corda
nome utente	corda
parola d’ordine	corda
	oggetto (clusterResourceQuota)
	oggetto (clusterLimitRange)

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

Esempio

K8S

{"nome": "corda",
"Descrizione": "corda",
"Depositi": {"proprietà1": {"sparkBucket": "corda",
"dataBucket": "corda",
"extraBuckets": ["corda"
],
"tipo": "S3",
"punto finale": "corda",
"region": "us-east-1",
"chiave di accesso": "corda",
"chiave segreta": "corda"
},
"proprietà2": {"sparkBucket": "corda",
"dataBucket": "corda",
"extraBuckets": ["corda"
],
"tipo": "S3",
"punto finale": "corda",
"region": "us-east-1",
"chiave di accesso": "corda",
"chiave segreta": "corda"
}
},
"sparkStorage": "S3",
"metastoreName": "corda",
"memorySettings": {"executors": "corda",
"driverCores": "corda",
"executorCores": "corda",
"driverMemory": "corda",
"executorMemory": "corda",
"dynamicAllocation": "falso",
"initialExecutors": "corda",
"minExecutors": "corda",
"maxExecutors": "corda"
},
"defaultApplicationConfig": "corda",
"tipo": "K8S",
"url": "corda",
"caCert": "corda",
"clientCert": "corda",
"clientKey": "corda",
"clientKeyAlgorithm": "corda",
"clientKeyPassphrase": "corda",
"nome utente": "corda",
"parola d'ordine": "corda",
"resourceQuota": {"limitsPod": "corda",
"limitsCpu": "corda",
"limitsMemory": "corda",
"requestsCpu": "corda",
"requestsMemory": "corda"
},
"limitRange": {"cpuLimitRange": {"defaultLimit": "corda",
"defaultRequest": "corda",
"minRequest": "corda",
"maxLimit": "corda",
"maxLimitRequestRatio": "corda"
},
"memoryLimitRange": {"defaultLimit": "corda",
"defaultRequest": "corda",
"minRequest": "corda",
"maxLimit": "corda",
"maxLimitRequestRatio": "corda"
}
}
}

Esempi di risposta

402
404
409

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Elimina un cluster in base al relativo ID

sentiero Parametri

clusterId

Obbligatorio

corda

Identificatore univoco di un cluster

quesito Parametri

force

boolean

Default: falso

Force delete flag

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Restituisce i nomi dei cluster esistenti

Risposte

Esempi di risposta

200

Tipo di contenuto

Applicazione/JSON

{"nomi": ["corda"
]
}

Creates a namespace for a cluster

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

nome

Obbligatorio

corda

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

{"nome": "corda"
}

Esempi di risposta

402
409

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Licenza

Restituisce lo stato corrente della licenza

Risposte

Esempi di risposta

200

Tipo di contenuto

Applicazione/JSON

{"Stato": "VERDE",
"Scadere": "corda"
}

Allega la chiave di licenza

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

chiave

Obbligatorio

corda

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

{"chiave": "corda"
}

Esempi di risposta

409

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

SQL

Returns information about SQL engines

sentiero Parametri

clusterId

Obbligatorio

corda

Identificatore univoco di un cluster

Risposte

Esempi di risposta

200
409

Tipo di contenuto

Applicazione/JSON

[{"id": "corda",
"tipo": "SPARK_SQL",
"Stato": "RUNNING"
}
]

Creates an SQL engine

sentiero Parametri

clusterId

Obbligatorio

corda

Identificatore univoco di un cluster

Schema del corpo della richiesta: Applicazione/JSON

digitare	corda (sqlEngineType) Default: "SPARK_SQL" Enumerazione: "SPARK_SQL" "TRINO"
async	boolean Default: falso If true, the request will return immediately, meaning that the engine may not be started yet
force	boolean Default: falso If true, when there is a starting engine, it will be stopped and a new one will be started

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

{"tipo": "SPARK_SQL",
"async": falso,
"force": falso
}

Esempi di risposta

200
402
409

Tipo di contenuto

Applicazione/JSON

{"id": "corda"
}

Shuts down an SQL engine by its id

sentiero Parametri

sqlEngineId

Obbligatorio

corda

The unique identifier of a SQL engine

Risposte

Esempi di risposta

402
404
409

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Executes an SQL statement

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

statement Obbligatorio	corda
clusterId	corda
maxRows	numero intero <int64> Default: 1000
engine	corda (sqlEngineType) Default: "SPARK_SQL" Enumerazione: "SPARK_SQL" "TRINO"

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

{"statement": "corda",
"clusterId": "corda",
"maxRows": 1000,
"engine": "SPARK_SQL"
}

Esempi di risposta

200
402
409

Tipo di contenuto

Applicazione/JSON

{"info": {"Stato": "corda",
"creationTime": 0,
"startTime": 0,
"completionTime": 0,
"exception": "corda"
},
"columns": [{"nome": "corda",
"tipo": "corda",
"index": 0,
"precision": 0,
"scala": 0,
"comment": "corda"
}
],
"rows": [[{ }
]
],
"logs": ["corda"
]
}

Returns paginated list of saved SQL statements

quesito Parametri

pagina	numero intero Default: 0 Il numero di pagine da restituire
grandezza	numero intero Default: 10 La dimensione della pagina da restituire
sorta	Matrice di Stringhe Esempio: sort=nome,asc Le regole di ordinamento da applicare definiscono l'ordine di paging
ricerca	corda La parola da applicare per il filtraggio

Risposte

Esempi di risposta

200
409

Tipo di contenuto

Applicazione/JSON

{"pagina": {"numero": 0,
"Taglia": 0,
"offset": 0,
"impaginato": vero
},
"ordina": ["corda"
],
"totalElements": 0,
"totalPages": 0,
"Primo": vero,
"ultimo": vero,
"vuoto": vero,
"contenuto": [{"id": "corda",
"nome": "corda",
"statement": "corda",
"engine": "SPARK_SQL",
"maxRows": 0
}
]
}

Saves an SQL statement

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

nome Obbligatorio	corda
statement Obbligatorio	corda
engine	corda (sqlEngineType) Default: "SPARK_SQL" Enumerazione: "SPARK_SQL" "TRINO"
maxRows	numero intero <int64>

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

{"nome": "corda",
"statement": "corda",
"engine": "SPARK_SQL",
"maxRows": 0
}

Esempi di risposta

200
402
409

Tipo di contenuto

Applicazione/JSON

{"id": "corda"
}

Returns a saved SQL statement found by its id

sentiero Parametri

sqlSavedId

Obbligatorio

corda

The unique identifier of a saved SQL statement

Risposte

Esempi di risposta

200
404

Tipo di contenuto

Applicazione/JSON

{"nome": "corda",
"statement": "corda",
"engine": "SPARK_SQL",
"maxRows": 0
}

Updates a saved SQL statement found by its id

sentiero Parametri

sqlSavedId

Obbligatorio

corda

The unique identifier of a saved SQL statement

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

nome Obbligatorio	corda
statement Obbligatorio	corda
engine	corda (sqlEngineType) Default: "SPARK_SQL" Enumerazione: "SPARK_SQL" "TRINO"
maxRows	numero intero <int64>

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

{"nome": "corda",
"statement": "corda",
"engine": "SPARK_SQL",
"maxRows": 0
}

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Deletes a saved SQL statement found by its id

sentiero Parametri

sqlSavedId

Obbligatorio

corda

The unique identifier of a saved SQL statement

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Returns a page of SQL notebooks

quesito Parametri

pagina	numero intero Default: 0 Il numero di pagine da restituire
grandezza	numero intero Default: 10 La dimensione della pagina da restituire
sorta	Matrice di Stringhe Esempio: sort=nome,asc Le regole di ordinamento da applicare definiscono l'ordine di paging
ricerca	corda La parola da applicare per il filtraggio

Risposte

Esempi di risposta

200
409

Tipo di contenuto

Applicazione/JSON

{"pagina": {"numero": 0,
"Taglia": 0,
"offset": 0,
"impaginato": vero
},
"ordina": ["corda"
],
"totalElements": 0,
"totalPages": 0,
"Primo": vero,
"ultimo": vero,
"vuoto": vero,
"contenuto": [{"id": "corda",
"nome": "corda",
"statements": [{"id": "corda",
"linguaggio": "SQL",
"code": "corda"
}
]
}
]
}

Creates an SQL notebook

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

nome	corda
	Matrice di objects (sqlNotebookCell)

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

{"nome": "corda",
"statements": [{"id": "corda",
"linguaggio": "SQL",
"code": "corda"
}
]
}

Esempi di risposta

200
402
409

Tipo di contenuto

Applicazione/JSON

{"id": "corda"
}

Returns an SQL notebook found by its id

sentiero Parametri

sqlNotebookId

Obbligatorio

corda

The unique identifier of an SQL notebook

Risposte

Esempi di risposta

200
404

Tipo di contenuto

Applicazione/JSON

{"id": "corda",
"nome": "corda",
"statements": [{"id": "corda",
"linguaggio": "SQL",
"code": "corda"
}
]
}

Updates an SQL notebook found by its id

sentiero Parametri

sqlNotebookId

Obbligatorio

corda

The unique identifier of an SQL notebook

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

nome	corda
	Matrice di objects (sqlNotebookCell)

Risposte

Richiedi campioni

Carico utile

Tipo di contenuto

Applicazione/JSON

{"nome": "corda",
"statements": [{"id": "corda",
"linguaggio": "SQL",
"code": "corda"
}
]
}

Esempi di risposta

402
404
409

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Deletes an SQL notebook found by its id

sentiero Parametri

sqlNotebookId

Obbligatorio

corda

The unique identifier of an SQL notebook

Risposte

Esempi di risposta

402
404

Tipo di contenuto

Applicazione/JSON

{"messaggio": "corda"
}

Ilum API (1.5.3)

Gruppo

Restituisce una pagina di gruppi esistenti

quesito Parametri

Risposte

Esempi di risposta

Crea un gruppo di processi Spark interattivi

Schema del corpo della richiesta: multipart/form-dataObbligatorio

Risposte

Esempi di risposta

Restituisce un gruppo trovato in base al suo id

sentiero Parametri

Risposte

Esempi di risposta

Elimina un gruppo in base al suo id

sentiero Parametri

Risposte

Esempi di risposta

Updates a group by its id

sentiero Parametri

Schema del corpo della richiesta: multipart/form-dataObbligatorio

Risposte

Esempi di risposta

Esegue un processo Spark interattivo all'interno del gruppo scelto

sentiero Parametri

Schema del corpo della richiesta: Applicazione/JSONObbligatorio

Risposte

Richiedi campioni

Esempi di risposta

Restituisce una pagina di risultati dell'istanza del processo di gruppo esistente

sentiero Parametri

quesito Parametri

Risposte

Esempi di risposta

Invia un processo Spark interattivo all'interno del gruppo scelto

sentiero Parametri

Schema del corpo della richiesta: Applicazione/JSONObbligatorio

Risposte

Richiedi campioni

Esempi di risposta

Modifica il numero di processi Spark interattivi usati dal gruppo scelto

sentiero Parametri

Risposte

Esempi di risposta

Restarts a chosen group

sentiero Parametri

Risposte

Esempi di risposta

Pauses a chosen group

sentiero Parametri

Risposte

Esempi di risposta

Resumes a chosen group

sentiero Parametri

Risposte

Esempi di risposta

Arresta un gruppo scelto e lo mette in stato ARCHIVIATO

sentiero Parametri

Risposte

Esempi di risposta

Restituisce un flusso di modifiche interattive ai risultati del processo Spark

quesito Parametri

Risposte

Restituisce un gruppo trovato in base al nome

sentiero Parametri

Risposte

Esempi di risposta

Programma

Returns a page of existing schedules

quesito Parametri

Risposte

Esempi di risposta

Creates a schedule of single Spark jobs

Schema del corpo della richiesta: multipart/form-dataObbligatorio

Risposte

Esempi di risposta

Returns a schedule found by its id

sentiero Parametri

Risposte

Esempi di risposta

Schema del corpo della richiesta: multipart/form-data
Obbligatorio

Schema del corpo della richiesta: multipart/form-data
Obbligatorio

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio

Schema del corpo della richiesta: multipart/form-data
Obbligatorio

Schema del corpo della richiesta: multipart/form-data
Obbligatorio

Schema del corpo della richiesta: multipart/form-data
Obbligatorio

Schema del corpo della richiesta: Applicazione/JSON
Obbligatorio