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
spark_parse_time
反馈
提交和查看相关反馈