Contexto do servidor analítico

Retorna a instância do Pyspark python SparkContext :

cxt.getSparkContext() : SparkContext

Retorna a instância do Pyspark python SQLContext :

cxt.getSparkSQLContext() : SQLContext

Retorna True para descrever se a execução é feita apenas para calcular o modelo de dados de saída Caso contrário, retorna False:

cxt.isComputeDataModelOnly() : Boolean

Retorna True se o script estiver em execução no ambiente Spark. Atualmente, ele sempre retorna True:

cxt.isSparkExecution() : Boolean

Carrega dados de entrada do arquivo temporário de envio de dados e gera a instância pyspark.sql.DataFrame :

cxt.getSparkInputData() : DataFrame

Retorna uma instância do pyspark.sql.StructType gerada a partir do modelo de dados de entrada Retorna None se o modelo de dados de entrada não existir:

cxt.getSparkInputSchema() : StructType

Serializa o quadro de dados de saída no contexto do Analytic Server e retorna o contexto:

cxt.setSparkOutputData( outDF) : AnalyticServerContext

Parâmetro:

• outDF (DataFrame) : O valor do quadro de dados de saída

Exceções:

• DataOutputNotSupported : Se esta interface for invocada na função pyspark:buildmodel
• ASContextException : Se o quadro de dados de saída for None
• InconsistentOutputDataModel : Os nomes de campo e informações do tipo de armazenamento comuns a ambos os objetos é inconsistente

Converte a instância do outSchema StructType em um modelo de dados, serializa-a no contexto do Analytic Server e retorna o contexto:

cxt.setSparkOutputSchema(outSchema) : AnalyticServerContext

Parâmetro:

• outSchema(StructType) : A saída StructType objeto

Exceções:

• ASContextException : Se a instância do esquema de saída for None
• InconsistentOutputDataModel : Os nomes de campo e informações do tipo de armazenamento comuns a ambos os objetos é inconsistente

Armazena o local da saída de construção de modelo para o contexto do Analytic Server e retorna o contexto:

cxt.setModelContentFromPath(key, path, mimetype=None) : AnalyticServerContext

O caminho pode ser um caminho do diretório que deve usar a API cxt.createTemporaryFolder() para gerar, quando tudo sob o diretório é empacotado como conteúdo de modelo

Parâmetros:

• key (string) : valor da sequência de chaves
• path (string) : localização do caminho de cadeia de saída do prédio do modelo
• mimetype (string, optional) : o tipo MIME do conteúdo

Exceções:

• ModelOutputNotSupported : Quando não invoca essa API da função pyspark:buildmodel
• KeyError : Se o atributo chave for None ou a string estiver vazia

Armazena o conteúdo de construção de modelo, metadados ou outros atributos no contexto do Analytic Server e retorna o contexto:

cxt.setModelContentFromString(key, value, mimetype=None) : AnalyticServerContext

Parâmetros:

• key (string) : valor da sequência de chaves
• value (string) : o valor da cadeia de metadados do modelo
• mimetype (string, optional) : o tipo MIME do conteúdo

Exceções:

• ModelOutputNotSupported : Quando não invoca essa API da função pyspark:buildmodel
• KeyError : Se o atributo chave for None ou a string estiver vazia

Retorna o local da pasta temporária que é gerenciado pelo Analytic Server; isso pode ser usado para armazenar o conteúdo do modelo:

cxt.createTemporaryFolder() : string

Exceção:

• ModelOutputNotSupported : Quando não invoca essa API da função pyspark:buildmodel

Retorna o local do modelo que corresponde à chave de entrada:

cxt.getModelContentToPath(key) : string

Parâmetro:

• key (string) : valor da sequência de chaves

Exceções:

• ModelInputNotSupported : Quando não invoca essa API da função pyspark:applymodel
• KeyError : Se o atributo chave for None ou a string estiver vazia
• IncompatibleModelContentType : Se o tipo de conteúdo do modelo não for um container

Retorna o conteúdo do modelo, metadados do modelo ou outros atributos de modelo que correspondem à chave de entrada:

cxt.getModelContentToString(key) : string

Parâmetro:

• key (string) : valor da sequência de chaves

Exceções:

• ModelInputNotSupported : Quando não invoca essa API da função pyspark:applymodel
• KeyError : Se o atributo chave for None, ou a string estiver vazia, ou a chave não existir
• IncompatibleModelContentType : Se o tipo de conteúdo do modelo não for consistente

Retorna o tipo mime designado para a chave de entrada Ele retornará None se o conteúdo especificado não tiver nenhum tipo mime:

cxt.getModelContentMimeType(key) : string

Parâmetro:

• key (string) : valor da sequência de chaves

Exceções:

• ModelInputNotSupported : Quando não invoca essa API da função pyspark:applymodel
• KeyError : Se o atributo chave for None, ou a string estiver vazia, ou a chave não existir