Как получить данные из облачного хранилища, используя API Java Cloud-Cloudant из облачного представления

Я хотел бы знать, как получить данные из облачных представлений, используя API-интерфейс spark-cloudant на языке Java.

У меня также есть требование отфильтровать результат просмотра по ключам. При этом из облачного хранилища будет загружен только ограниченный набор документов. Размер облачной БД составляет почти 100 ГБ. Таким образом, загрузка всей облачной БД с использованием spark-Cloudant и локальная фильтрация в коде Java не работают для меня. Вот почему я хотел бы использовать подход облачного представления, вызываемый из API-интерфейса облачного облака.

Dataset<Row> dbData =   sparkSession.read()
            .format("com.cloudant.spark")
            .option("cloudant.host", AppConstants.CLOUDANT_ACCOUNT_NAME + ".cloudant.com")
            .option("cloudant.username", AppConstants.CLOUDANT_USERNAME)
            .option("cloudant.password", AppConstants.CLOUDANT_PASSWORD)
            .option("database", AppConstants.DB_APPLICANT)
            .option("indexName", "applicantIndex")
            .option("viewName", "getApplicantByJobId")
            .load();


    dbData.show();

Я могу видеть выходные данные из cloudant, если я просто закомментирую последние два параметра (). Как только я добавлю его, я получу возможность увидеть весь вывод БД вместо вывода из облачного представления.

0 ответов

Другие вопросы по тегам