public void deleteByKey()

in core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java [184:221]

• 30 lines of code
• 7 McCabe index (conditional complexity)

        public void deleteByKey(byte[] key) {
            {
                Set<Map.Entry<String, Set<byte[]>>> entries = calculating.entrySet();
                Iterator<Map.Entry<String, Set<byte[]>>> iterator = entries.iterator();
                while (iterator.hasNext()) {
                    Map.Entry<String, Set<byte[]>> next = iterator.next();

                    Set<byte[]> keySet = next.getValue();

                    if (keySet != null) {
                        keySet.removeIf(rocksDBKey -> Arrays.equals(rocksDBKey, key));
                        if (keySet.size() == 0) {
                            iterator.remove();
                        }
                    }
                }
            }

            {
                Set<Map.Entry<String, Set<byte[]>>> entries = recover.entrySet();
                Iterator<Map.Entry<String, Set<byte[]>>> iterator = entries.iterator();
                while (iterator.hasNext()) {
                    Map.Entry<String, Set<byte[]>> next = iterator.next();

                    Set<byte[]> keySet = next.getValue();

                    if (keySet != null) {
                        keySet.removeIf(rocksDBKey -> Arrays.equals(rocksDBKey, key));
                        if (keySet.size() == 0) {
                            iterator.remove();
                        }
                    }
                }
            }



        }