test_class.declarator: marshaller
test_class.modifier: private
test_class.original_string: private JdkMarshaller marshaller;
test_class.type: JdkMarshaller
test_class.var_name: marshaller
test_class.declarator: bridge
test_class.modifier: private
test_class.original_string: private InMemoryCachedDistributedMetaStorageBridge bridge;
test_class.type: InMemoryCachedDistributedMetaStorageBridge
test_class.var_name: bridge
test_class.file: modules/core/src/test/java/org/apache/ignite/internal/processors/metastorage/persistence/InMemoryCachedDistributedMetaStorageBridgeTest.java
test_class.identifier: InMemoryCachedDistributedMetaStorageBridgeTest
test_case.body: @Test
      public void testIterate() throws Exception {
          bridge.write("key3", marshaller.marshal("val3"));
          bridge.write("key1", marshaller.marshal("val1"));
          bridge.write("key2", marshaller.marshal("val2"));
          bridge.write("xey4", marshaller.marshal("val4"));
  
          List<String> keys = new ArrayList<>();
          List<String> values = new ArrayList<>();
  
          bridge.iterate("key", (key, value) -> {
              assertThat(value, is(instanceOf(String.class)));
  
              keys.add(key);
              values.add((String)value);
          });
  
          assertEquals(asList("key1", "key2", "key3"), keys);
          assertEquals(asList("val1", "val2", "val3"), values);
      }
test_case.class_method_signature: InMemoryCachedDistributedMetaStorageBridgeTest.testIterate()
test_case.full_signature: @Test public void testIterate()
test_case.identifier: testIterate
test_case.invocations: write marshal write marshal write marshal write marshal iterate assertThat is instanceOf add add assertEquals asList assertEquals asList
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testIterate()
focal_class.declarator: marshaller
focal_class.modifier: private final
focal_class.original_string: private final JdkMarshaller marshaller;
focal_class.type: JdkMarshaller
focal_class.var_name: marshaller
focal_class.declarator: cache = new TreeMap<>()
focal_class.modifier: private final
focal_class.original_string: private final SortedMap<String, byte[]> cache = new TreeMap<>();
focal_class.type: SortedMap<String, byte[]>
focal_class.var_name: cache
focal_class.file: modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/InMemoryCachedDistributedMetaStorageBridge.java
focal_class.identifier: InMemoryCachedDistributedMetaStorageBridge
focal_class.class_method_signature: InMemoryCachedDistributedMetaStorageBridge.InMemoryCachedDistributedMetaStorageBridge(JdkMarshaller marshaller)
focal_class.full_signature: public  InMemoryCachedDistributedMetaStorageBridge(JdkMarshaller marshaller)
focal_class.identifier: InMemoryCachedDistributedMetaStorageBridge
focal_class.modifiers: public
focal_class.parameters: (JdkMarshaller marshaller)
focal_class.signature:  InMemoryCachedDistributedMetaStorageBridge(JdkMarshaller marshaller)
focal_class.class_method_signature: InMemoryCachedDistributedMetaStorageBridge.read(String globalKey)
focal_class.full_signature: public Serializable read(String globalKey)
focal_class.identifier: read
focal_class.modifiers: public
focal_class.parameters: (String globalKey)
focal_class.return: Serializable
focal_class.signature: Serializable read(String globalKey)
focal_class.class_method_signature: InMemoryCachedDistributedMetaStorageBridge.readMarshalled(String globalKey)
focal_class.full_signature: public byte[] readMarshalled(String globalKey)
focal_class.identifier: readMarshalled
focal_class.modifiers: public
focal_class.parameters: (String globalKey)
focal_class.return: byte[]
focal_class.signature: byte[] readMarshalled(String globalKey)
focal_class.class_method_signature: InMemoryCachedDistributedMetaStorageBridge.iterate(
          String globalKeyPrefix,
          BiConsumer<String, ? super Serializable> cb
      )
focal_class.full_signature: public void iterate(
          String globalKeyPrefix,
          BiConsumer<String, ? super Serializable> cb
      )
focal_class.identifier: iterate
focal_class.modifiers: public
focal_class.parameters: (
          String globalKeyPrefix,
          BiConsumer<String, ? super Serializable> cb
      )
focal_class.return: void
focal_class.signature: void iterate(
          String globalKeyPrefix,
          BiConsumer<String, ? super Serializable> cb
      )
focal_class.class_method_signature: InMemoryCachedDistributedMetaStorageBridge.write(String globalKey, @Nullable byte[] valBytes)
focal_class.full_signature: public void write(String globalKey, @Nullable byte[] valBytes)
focal_class.identifier: write
focal_class.modifiers: public
focal_class.parameters: (String globalKey, @Nullable byte[] valBytes)
focal_class.return: void
focal_class.signature: void write(String globalKey, @Nullable byte[] valBytes)
focal_class.class_method_signature: InMemoryCachedDistributedMetaStorageBridge.localFullData()
focal_class.full_signature: public DistributedMetaStorageKeyValuePair[] localFullData()
focal_class.identifier: localFullData
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: DistributedMetaStorageKeyValuePair[]
focal_class.signature: DistributedMetaStorageKeyValuePair[] localFullData()
focal_class.class_method_signature: InMemoryCachedDistributedMetaStorageBridge.writeFullNodeData(DistributedMetaStorageClusterNodeData fullNodeData)
focal_class.full_signature: public void writeFullNodeData(DistributedMetaStorageClusterNodeData fullNodeData)
focal_class.identifier: writeFullNodeData
focal_class.modifiers: public
focal_class.parameters: (DistributedMetaStorageClusterNodeData fullNodeData)
focal_class.return: void
focal_class.signature: void writeFullNodeData(DistributedMetaStorageClusterNodeData fullNodeData)
focal_class.class_method_signature: InMemoryCachedDistributedMetaStorageBridge.readInitialData(
          ReadOnlyMetastorage metastorage
      )
focal_class.full_signature: public DistributedMetaStorageVersion readInitialData(
          ReadOnlyMetastorage metastorage
      )
focal_class.identifier: readInitialData
focal_class.modifiers: public
focal_class.parameters: (
          ReadOnlyMetastorage metastorage
      )
focal_class.return: DistributedMetaStorageVersion
focal_class.signature: DistributedMetaStorageVersion readInitialData(
          ReadOnlyMetastorage metastorage
      )
focal_method.body: public void iterate(
          String globalKeyPrefix,
          BiConsumer<String, ? super Serializable> cb
      ) throws IgniteCheckedException {
          for (Map.Entry<String, byte[]> entry : cache.tailMap(globalKeyPrefix).entrySet()) {
              if (!entry.getKey().startsWith(globalKeyPrefix))
                  break;
  
              cb.accept(entry.getKey(), unmarshal(marshaller, entry.getValue()));
          }
      }
focal_method.class_method_signature: InMemoryCachedDistributedMetaStorageBridge.iterate(
          String globalKeyPrefix,
          BiConsumer<String, ? super Serializable> cb
      )
focal_method.full_signature: public void iterate(
          String globalKeyPrefix,
          BiConsumer<String, ? super Serializable> cb
      )
focal_method.identifier: iterate
focal_method.invocations: entrySet tailMap startsWith getKey accept getKey unmarshal getValue
focal_method.modifiers: public
focal_method.parameters: (
          String globalKeyPrefix,
          BiConsumer<String, ? super Serializable> cb
      )
focal_method.return: void
focal_method.signature: void iterate(
          String globalKeyPrefix,
          BiConsumer<String, ? super Serializable> cb
      )