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());
}
}