Если у вас есть паркетная версия, вы можете просто скопировать имена столбцов, что я и сделал (также столбец даты был разделом ключа для orc, поэтому пришлось переместить его в конец):
tx = sqlContext.table("tx_parquet")
df = sqlContext.table("tx_orc")
tx_cols = tx.schema.names
tx_cols.remove('started_at_date')
tx_cols.append('started_at_date') #move it to end
#fix column names for orc
oldColumns = df.schema.names
newColumns = tx_cols
df = functools.reduce(
lambda df, idx: df.withColumnRenamed(
oldColumns[idx], newColumns[idx]), range(
len(oldColumns)), df)
Я считаю, что это не может быть сделано. Поскольку основной целью tf.get_variable()
является поиск переменной с тем же именем, а если она не найдена, она создает новую. Поэтому, если вы просто хотите создать новую переменную, используйте tf.Variable()
вместо