propriedades extensionexportnode
Com o nó Extensão Exportar, você pode executar R ou Python para scripts Spark para exportar dados.
Exemplo de Python for 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)
Exemplo de R
node.setPropertyValue("syntax_type", "R")
node.setPropertyValue("r_syntax", """write.csv(modelerData, "/opt/IBM/SPSS/ModelerServer/Cloud/demos/ export.csv")""")
propriedades extensionexportnode |
Tipo de dados | Descrição da propriedade |
|---|---|---|
syntax_type |
R Python | Especifique qual script executa: R ou Python (R é o padrão). |
r_syntax |
sequência | A sintaxe de script do R a ser executada. |
python_syntax |
sequência | A sintaxe de script Python a ser executada. |
convert_flags |
|
Opção para converter os campos de sinalização. |
convert_missing |
sinalização | Opção para converter valores ausentes para o RNAvalor. |
convert_datetime |
sinalização | Opção para converter variáveis com os formatos de data ou data/hora em formatos de data/hora R. |
convert_datetime_class |
|
Opções para especificar em qual formato as variáveis com os formatos de data ou data/hora serão convertidas. |