sparkEmbeddedProcess

executeProgram

Beschreibung

Führt beliebige Programme innerhalb des SAS Embedded Process für Spark aus. Diese Aktion ermöglicht die direkte Ausführung von nutzerdefiniertem Scala-Code in der Spark-Umgebung.

Einstellungen
ParameterBeschreibung
caslibGibt die Caslib an, die die Datenquellenoptionen enthält. (Alias: datasourceFromCasLib)
programGibt das beliebige Scala-Programm im Klartext an, das innerhalb von Spark unter Verwendung des SAS Embedded Process ausgeführt wird.
programFileGibt einen lokalen Dateinamen an, der ein beliebiges Scala-Programm enthält, das zur Ausführung innerhalb von Spark unter Verwendung des SAS Embedded Process übermittelt wird.
Vorbereitung der Spark-Sitzung

Stellt sicher, dass eine CAS-Sitzung läuft und eine Verbindung zur Spark-Datenquelle besteht.

Kopiert!
1cas mySession sessopts=(caslib='casuser');
2LIBNAME casuser cas caslib='casuser';
3 

Beispiele

Demonstriert die Ausführung eines einfachen 'Hello World' Scala-Befehls direkt über den Parameter 'program'.

SAS® / CAS-Code Code wartet auf Validierung durch die Community
Kopiert!
1PROC CAS;
2 sparkEmbeddedProcess.executeProgram /
3 caslib="sparkLib",
4 program="println(\"Hello from SAS Embedded Process\")";
5RUN;
Ergebnis :
Der Scala-Befehl wird erfolgreich im verbundenen Spark-Cluster ausgeführt.

Zeigt, wie ein komplexeres Scala-Programm, das lokal in einer Datei gespeichert ist, referenziert und ausgeführt wird.

SAS® / CAS-Code Code wartet auf Validierung durch die Community
Kopiert!
1PROC CAS;
2 sparkEmbeddedProcess.executeProgram /
3 caslib="sparkLib",
4 programFile="/pfad/zu/skript.scala";
5RUN;
Ergebnis :
Das in der Datei enthaltene Scala-Programm wird geladen und innerhalb des SAS Embedded Process für Spark ausgeführt.

FAQ

Was ist die "executeProgram" Aktion?
Was ist der "caslib"-Parameter?
Was ist der "program"-Parameter?
Was ist der "programFile"-Parameter?