Spark AttributeError: 'DataFrame' - Objekt hat kein Attribut 'weekofyear'

Muss ich bekommen die Nummer der Woche des Jahres

      from pyspark.sql.functions import weekofyear
      dt =sqlContext.createDataFrame([('2015-04-08',)], ['a'])
      dt = dt.weekofyear(dt.a).alias('week')
      dt.show()

Aber bekam ich diese Fehlermeldung:AttributeError: 'DataFrame' - Objekt hat kein Attribut 'weekofyear'

Irgendeine Idee?
Dank

InformationsquelleAutor newleaf | 2017-01-04
  1. 1

    Folgende funktioniert einwandfrei.

     from pyspark.sql.functions import weekofyear
 dt =sqlContext.createDataFrame([('2015-04-08',)], ['a'])
 dt = dt.select('*',weekofyear(dt.a).alias('week'))
 dt.show()
    InformationsquelleAutor newleaf
  2. 0

    Ich denke, es sollte sein:

    weekofyear(dt.a).alias('week')

    statt:

    dt.weekofyear(dt.a).alias('week')

    als weekofyear() ist eine SQL-Funktion - es ist nicht ein DataFrame Methode...

    • Vielen Dank für Ihre Mahnung.Ich habe die änderungen vorgenommen und es funktioniert wie folgt
    InformationsquelleAutor MaxU
Schreibe einen Kommentar