
Я пытаюсь подключиться к Snowflake с помощью API сноупарка с доступом ACCOUNTADMIN. получаю ошибку ниже, когда пытаюсь объединиться. Я делаю что-то не так.
Код: Выделить всё
Updatable dfFull = session.table("RATINGS");
Updatable df = session.table("RATINGS_MOVIE_328");
..
RATINGS_MOVIE_328 table is subset of RATINGS table whose movieid is 328
..
MergeBuilder mb = dfFull.merge(updatedDf,dfFull.col("USERID").equal_to(updatedDf.col("USERID")));
Map assignments = new HashMap();
assignments.put("RATING", updatedDf.col("RATING"));
..
MergeResult mr = mb.whenMatched().updateColumn(assignments).collect();
ОБЪЕДИНЯЙТЕ В РЕЙТИНГИ С ИСПОЛЬЗОВАНИЕМ (ВЫБЕРИТЕ «USERID» AS «r_J1pF_USERID», «MOVIEID» AS «r_J1pF_MOVIEID», «RATING» AS «r_J1pF_RATING», « TIMESTAMP» AS «r_J1pF_TIMESTAMP» FROM ( SELECT «USERID», «MOVIEID», to_decimal («RATING», 38, 4) AS «RATING», «TIMESTAMP» FROM ( SELECT * FROM (SNOWPARK_TEMP_TABLE_GUYM0ZTBCG2K2R7)))) ON («USERID» " = "r_J1pF_USERID") ПРИ СООТВЕТСТВИИ ТОГДА ОБНОВЛЕНИЕ SET "RATING" = "r_J1pF_RATING"
net.snowflake.client.jdbc.SnowflakeSQLException: ошибка компиляции SQL:
Объект 'SNOWPARK_TEMP_TABLE_GUYM0ZTBCG2K2R7' не существует или не авторизован .
Подробнее здесь: https://stackoverflow.com/questions/783 ... ror-object