public KuduSourceSplit deserialize()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/split/KuduSourceSplitSerializer.java [44:53]

• 9 lines of code
• 4 McCabe index (conditional complexity)

    public KuduSourceSplit deserialize(int version, byte[] serialized) throws IOException {
        if (version != CURRENT_VERSION) {
            throw new IllegalArgumentException("Unsupported version: " + version);
        }
        if (serialized == null || serialized.length == 0) {
            throw new IOException("Serialized data is empty or null.");
        }

        return new KuduSourceSplit(serialized); // Recreate the split with the byte array
    }