dias
Função de transformação de partição: Uma transformação para registros de data e hora, que permite particionar dados em dias. Compatível com Spark Connect.
atenção
Obsoleto na versão 4.0.0. Use partitioning.days em vez disso.
Sintaxe
Python
from pyspark.databricks.sql import functions as dbf
dbf.days(col=<col>)
Parâmetros
Parâmetro | Tipo | Descrição |
|---|---|---|
|
| Coluna de data ou hora de destino na qual trabalhar. |
Devoluções
pyspark.sql.ColumnDados divididos por dias.
Exemplos
Python
df.writeTo("catalog.db.table").partitionedBy(
days("ts")
).createOrReplace()
nota
Esta função só pode ser usada em combinação com o método partitionedBy do DataFrameWriterV2.