MongoDB Output Connector


链接库路径为'MongoDBOutputConnector'。 默认ID为'mongodbout'。 支持参数:

  • uri: (必需提供) STRING格式。连接的URI地址, 如mongodb://[user:password@]ip[:port]/database.collection[?...]。
  • auth_uri: (非必需) STRING格式。 认证地址。
  • key_field: (非必需) STRING格式。 含Row Key值的列名。
  • output_method: (非必需) STRING格式。 写出数据的方法。支持的方法包括 'default'。 默认值为 'default'。
  • output_overwrite: (非必需) BOOLEAN格式。 是否覆盖现有内容。默认值为FALSE 。

注: MongoDB Output Connector需要设HDFS里的临时目录,加集群的master、port等合适的值到 hadoop的mapred-site.xml:

  <property>
    <name>mapreduce.task.tmp.dir</name>
    <value>hdfs://master:port/tmp/</value>
  </property>