public void serializeMongoSplit()

in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitSerializer.java [73:85]


    public void serializeMongoSplit(DataOutputStream out, MongoSourceSplit obj) throws IOException {
        if (obj instanceof MongoScanSourceSplit) {
            MongoScanSourceSplit split = (MongoScanSourceSplit) obj;
            out.writeInt(SCAN_SPLIT_FLAG);
            out.writeUTF(split.splitId());
            out.writeUTF(split.getDatabase());
            out.writeUTF(split.getCollection());
            out.writeUTF(split.getMin().toJson());
            out.writeUTF(split.getMax().toJson());
            out.writeUTF(split.getHint().toJson());
            out.writeInt(split.getOffset());
        }
    }