in java/src/main/java/com/google/cloud/dataproc/templates/databases/MongoToGCS.java [82:100]
public void validateInput() {
if (StringUtils.isAllBlank(inputCollection)
|| StringUtils.isAllBlank(outputFileFormat)
|| StringUtils.isAllBlank(outputFileLocation)
|| StringUtils.isAllBlank(inputUri)
|| StringUtils.isAllBlank(inputDatabase)) {
LOGGER.error(
"{},{},{},{},{} are required parameter. ",
MONGO_GCS_INPUT_COLLECTION,
MONGO_GCS_OUTPUT_FORMAT,
MONGO_GCS_OUTPUT_LOCATION,
MONGO_GCS_INPUT_URI,
MONGO_GCS_INPUT_DATABASE);
throw new IllegalArgumentException(
"Required parameters for Mongo to GCS not passed. "
+ "Set mandatory parameter for Mongo to GCS template "
+ "in resources/conf/template.properties file.");
}
}