1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
| import sys
import pyspark.sql.functions as F
from pyspark.sql.functions import when, datediff, dayofmonth, substring, month, year, lit, desc, concat_ws, regexp_replace, dense_rank, row_number, lag, max, lead, to_date, countDistinct, current_date, date_format, concat_ws
from pyspark.sql.types import StructField, StructType, StringType, IntegerType, TimestampType, ArrayType, DecimalType, DateType
from pyspark.sql import DataFrame, SQLContext, Row
from datetime import datetime, timedelta, date
from pyspark.sql.window import Window
def yet(annee,mois):
an=annee
moi=mois
tab11=fd("produit",""+an+"-"+moi+"",archive=True)\
.select(F.col("CD_RUE").alias("CODE_rue"), F.col("LB_FDF").alias("NOM_FDF"))
return(tab11)
yet("2022","05") |
