public void serializePulsarPartitionSplit()

in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplitSerializer.java [83:109]

20 lines of code
3 McCabe index (conditional complexity)


    public void serializePulsarPartitionSplit(DataOutputStream out, PulsarPartitionSplit split)
            throws IOException {
        // partition
        serializeTopicPartition(out, split.getPartition());

        // stopCursor
        serializeObject(out, split.getStopCursor());

        // latestConsumedId
        MessageId latestConsumedId = split.getLatestConsumedId();
        if (latestConsumedId == null) {
            out.writeBoolean(false);
        } else {
            out.writeBoolean(true);
            serializeBytes(out, latestConsumedId.toByteArray());
        }

        // uncommittedTransactionId
        TxnID uncommittedTransactionId = split.getUncommittedTransactionId();
        if (uncommittedTransactionId == null) {
            out.writeBoolean(false);
        } else {
            out.writeBoolean(true);
            out.writeLong(uncommittedTransactionId.getMostSigBits());
            out.writeLong(uncommittedTransactionId.getLeastSigBits());
        }
    }