Lỗi khi convert pandas dataframe qua spark dataframe
Ví dụ: import pandas as pdimport pyspark.pandas as psfrom pyspark.sql import SparkSession # Giả sử bạn đã đọc dữ liệu từ Excel bằng Pandasdf_pandas = pd.read_excel(“your_file.xlsx”) # Chuyển đổi cột thời gian từ time64[us] sang string để tránh lỗidf_pandas[‘time_column’] = df_pandas[‘time_column’].astype(str) # Sau đó chuyển Pandas DataFrame sang Spark DataFramespark = SparkSession.builder.getOrCreate()df_spark = spark.createDataFrame(df_pandas) # […]