MongoUpsertSink.java 文件源码

@Override
public void open(Configuration config) {
    mongoClient = MongoManager.getInstance().getClient();
    uo = new UpdateOptions();
    uo.upsert(true);
    try {
        super.open(config);
    } catch (Exception e) {
        e.printStackTrace();
    }
}