public KuduSourceEnumeratorState deserialize()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/source/enumerator/KuduSourceEnumeratorStateSerializer.java [58:73]

• 13 lines of code
• 2 McCabe index (conditional complexity)

    public KuduSourceEnumeratorState deserialize(int version, byte[] serialized)
            throws IOException {
        if (version != CURRENT_VERSION) {
            throw new IllegalArgumentException("Unsupported version: " + version);
        }

        try (ByteArrayInputStream bais = new ByteArrayInputStream(serialized);
                DataInputStream in = new DataInputStream(bais)) {

            long lastEndTimestamp = in.readLong();
            List<KuduSourceSplit> unassigned = deserializeSplits(in);
            List<KuduSourceSplit> pending = deserializeSplits(in);

            return new KuduSourceEnumeratorState(lastEndTimestamp, unassigned, pending);
        }
    }