Могу ли я создать остальные API в Zeppelin и Pyspark? - PullRequest
Новая
       15

Могу ли я создать остальные API в Zeppelin и Pyspark?

0 голосов
/ 12 марта 2019

Я использую pyspark через zeppelin и пытаюсь создать остальные API для визуализации в угловых приложениях.

Например, у меня есть эта функция, которая возвращает ненулевые столбцы данного CSV-файла: 

def find_not_null_columns(file):
not_null_columns = []
for column in file.columns:
    null_count = file.filter((file[column] == "") | file[column].isNull()).count()
    if(null_count == 0):
        not_null_columns.append(column)
return not_null_columns

Я хочу построить остальные API, которые возвращают список not_null_columns и делают запрос к нему из angular, я хочу знать, возможно ли это,

Я использую свечи 2.3.2 и zeppelin 0.8.1.

...