Преобразовать столбец PySpark из целых чисел или bigint для хранения запятых - PullRequest
Новая
       15

Преобразовать столбец PySpark из целых чисел или bigint для хранения запятых

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

На данный момент у меня есть функция в PySpark, которая: def df_to_jira (df): «»» Необходимо преобразовать информационный фрейм в таблицу в формате JIRA Ограничивает количество возвращаемых строк до 100, гарантируя ограничение размера массива. / : param df: dataframe : return: str, таблица в формате JIRA, может быть вставлена ​​в том "" "

def df_to_jira(df):
    columnlist = list(df.columns)
    jira_table='||'+'||'.join(columnlist)+'||'
    for row in df.limit(100).collect():
        s=map(str,row)
        jira_table+='\n|'+'|'.join(s)+'|'
    #print(jira_table)
    return jira_table

Я хочу включить это 

for x, t in a.dtypes:
    if t=="bigint":
        (lambda x : "{:,}".format(x) # basically convert all the numbers to hold commas

так, чтобы в конечном итоге у меня мог быть фрейм данных с количеством запятых

...