Я пытаюсь установить соединение между Hive и DynamoDB через Spark. Для этого мне нужно выполнить этот код:
sparkSession.sql("create external table test (id string) STORED BY 'org.apache.hadoop.hive.dynamodb.DynamoDBStorageHandler' TBLPROPERTIES('dynamodb.table.name'='testdb','dynamodb.column.mapping'='id:id')")
Но у меня ошибка:
ParseException: u"\nOperation not allowed: STORED BY(line 1, pos 111)
Я где-то читал, что STORED BY
не поддерживается в Spark. Есть ли альтернативный метод? Это всегда не поддерживается? спасибо