我按年分区的创库语句如下,但是似乎创建出来的数据库依旧是按天分区的
def create_database(self) :
self.partition_value_array = np.array(pd.date_range(start = "20141231", end = "20241201", freq = "Y"), dtype="datetime64[D]")
self.current_database_path = "dfs://database_1"
self.current_database_name = "dfs_database_1"
if self.current_session.existsDatabase(self.current_database_path) :
self.current_session.dropDatabase(self.current_database_path)
self.current_dfs_database = self.current_session.database(dbName = self.current_database_name, partitionType = ddb.settings.VALUE, partitions = self.partition_value_array, dbPath = self.current_database_path)