time_data 模块

包含在 opendataset 中表示时间数据和相关操作的功能。

TimeCustomerData

表示包含时间的客户数据集。

TimeData

定义基时间数据类。

TimePublicData

表示包含时间的公共数据集。

函数

add_datetime_col

添加舍入的日期/时间列。

add_datetime_col(dataset: Union[pyspark.sql.dataframe.DataFrame, pandas.core.frame.DataFrame], time_col_name: str, time_func: object)

参数

dataset
time_col_name
time_func

extend_time_column

为字符串类型扩展时间列。

extend_time_column(dataset: Union[pyspark.sql.dataframe.DataFrame, pandas.core.frame.DataFrame], time_col_name: str, timeVal: Union[str, float, time.struct_time, datetime.datetime])

参数

dataset
time_col_name
timeVal

find_min_max_date

从 SPARK 数据帧中查找最小和最大日期。

find_min_max_date(dataset: Union[pyspark.sql.dataframe.DataFrame, pandas.core.frame.DataFrame], time_col_name: str)

参数

dataset
time_col_name

pd_parse_time

分析时间字符串并捕获异常。

pd_parse_time(time_string)

参数

time_string
str
必需

要分析的时间字符串。

spark_parse_time

分析时间字符串并捕获异常。

spark_parse_time(time_string)

参数

time_string
str
必需

要分析的时间字符串。