propriétés extensionexportnode
Avec le nœud Extension Export, vous pouvez exécuter R ou Python pour les scripts Spark afin d'exporter des données.
Python pour l'exemple Spark
import modeler.api
stream = modeler.script.stream()
node = stream.create("extension_export", "extension_export")
node.setPropertyValue("syntax_type", "Python")
python_script = """import spss.pyspark.runtime
from pyspark.sql import SQLContext
from pyspark.sql.types import *
cxt = spss.pyspark.runtime.getContext()
df = cxt.getSparkInputData()
print df.dtypes[:]
_newDF = df.select("Age","Drug")
print _newDF.dtypes[:]
df.select("Age", "Drug").write.save("/opt/IBM/SPSS/ModelerServer/Cloud/demos/Drug.json", format="json")
"""
node.setPropertyValue("python_syntax", python_script)
Exemple
node.setPropertyValue("syntax_type", "R")
node.setPropertyValue("r_syntax", """write.csv(modelerData, "/opt/IBM/SPSS/ModelerServer/Cloud/demos/ export.csv")""")
extensionexportnode properties |
Type de données | Description de la propriété |
|---|---|---|
syntax_type |
R Python | Spécifiez le script à exécuter : R ou Python (R est le script par défaut). |
r_syntax |
chaîne | La syntaxe de script R à exécuter. |
python_syntax |
chaîne | La syntaxe de script d' Python. |
convert_flags |
|
Possibilité de convertir les champs de drapeau. |
convert_missing |
option | Option permettant de convertir les valeurs manquantes en RNAvaleur. |
convert_datetime |
option | Possibilité de convertir les variables au format date ou date/heure en format R date/heure. |
convert_datetime_class |
|
Options permettant de spécifier le format dans lequel les variables de date ou de date et heure sont converties. |