Spark написать в Ignite на Ignite пользовательскую схему - PullRequest
Новая
       12

Spark написать в Ignite на Ignite пользовательскую схему

0 голосов
/ 06 февраля 2019

Я использую Spark 2.3.0 и Ignite 2.7.0, я создал собственные схемы в Ignite, используя 

<property name="sqlSchemas">
        <list>
            <value>dbsch</value>
            <value>dbschma</value>
            <value>db_ui</value>
        </list>
    </property>

Я мог бы создавать таблицы для каждой схемы.Но моя проблема в том, что я не могу загрузить данные в конкретную схему. 

df.write
          .format(FORMAT_IGNITE)
          .option(OPTION_CONFIG_FILE, CONFIG)
          .option(OPTION_TABLE, "db_ui."+tableName)
          .option(OPTION_CREATE_TABLE_PRIMARY_KEY_FIELDS, primaryKey)
          .option(OPTION_CREATE_TABLE_PARAMETERS, "template=replicated")
          .mode(SaveMode.Append)
          .save()

Он пытается создать таблицу в виде df и в конце концов терпит неудачу, говоря ноль в Spark Config.Это работает, если я пытаюсь загрузить таблицу в публичной (по умолчанию) схеме.Я получаю ту же ошибку, если пытаюсь читать из Ignite.Любой вклад, пожалуйста?

Ясень

...