test_class.declarator: stringSerde = Serdes.String()
test_class.modifier: final private
test_class.original_string: final private Serde<String> stringSerde = Serdes.String();
test_class.type: Serde<String>
test_class.var_name: stringSerde
test_class.declarator: driver = null
test_class.modifier: private
test_class.original_string: private KStreamTestDriver driver = null;
test_class.type: KStreamTestDriver
test_class.var_name: driver
test_class.declarator: stateDir = null
test_class.modifier: private
test_class.original_string: private File stateDir = null;
test_class.type: File
test_class.var_name: stateDir
test_class.file: streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableSourceTest.java
test_class.identifier: KTableSourceTest
test_case.body: @Test
      public void testValueGetter() throws IOException {
          final KStreamBuilder builder = new KStreamBuilder();
  
          String topic1 = "topic1";
  
          KTableImpl<String, String, String> table1 = (KTableImpl<String, String, String>) builder.table(stringSerde, stringSerde, topic1);
  
          KTableValueGetterSupplier<String, String> getterSupplier1 = table1.valueGetterSupplier();
  
          driver = new KStreamTestDriver(builder, stateDir, null, null);
  
          KTableValueGetter<String, String> getter1 = getterSupplier1.get();
          getter1.init(driver.context());
  
          driver.process(topic1, "A", "01");
          driver.process(topic1, "B", "01");
          driver.process(topic1, "C", "01");
  
          assertEquals("01", getter1.get("A"));
          assertEquals("01", getter1.get("B"));
          assertEquals("01", getter1.get("C"));
  
          driver.process(topic1, "A", "02");
          driver.process(topic1, "B", "02");
  
          assertEquals("02", getter1.get("A"));
          assertEquals("02", getter1.get("B"));
          assertEquals("01", getter1.get("C"));
  
          driver.process(topic1, "A", "03");
  
          assertEquals("03", getter1.get("A"));
          assertEquals("02", getter1.get("B"));
          assertEquals("01", getter1.get("C"));
  
          driver.process(topic1, "A", null);
          driver.process(topic1, "B", null);
  
          assertNull(getter1.get("A"));
          assertNull(getter1.get("B"));
          assertEquals("01", getter1.get("C"));
  
      }
test_case.class_method_signature: KTableSourceTest.testValueGetter()
test_case.full_signature: @Test public void testValueGetter()
test_case.identifier: testValueGetter
test_case.invocations: table valueGetterSupplier get init context process process process assertEquals get assertEquals get assertEquals get process process assertEquals get assertEquals get assertEquals get process assertEquals get assertEquals get assertEquals get process process assertNull get assertNull get assertEquals get
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testValueGetter()
focal_class.declarator: topic
focal_class.modifier: public final
focal_class.original_string: public final String topic;
focal_class.type: String
focal_class.var_name: topic
focal_class.declarator: materialized = false
focal_class.modifier: private
focal_class.original_string: private boolean materialized = false;
focal_class.type: boolean
focal_class.var_name: materialized
focal_class.declarator: sendOldValues = false
focal_class.modifier: private
focal_class.original_string: private boolean sendOldValues = false;
focal_class.type: boolean
focal_class.var_name: sendOldValues
focal_class.file: streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java
focal_class.identifier: KTableSource
focal_class.interfaces: implements ProcessorSupplier<K, V>
focal_class.class_method_signature: KTableSource.KTableSource(String topic)
focal_class.full_signature: public  KTableSource(String topic)
focal_class.identifier: KTableSource
focal_class.modifiers: public
focal_class.parameters: (String topic)
focal_class.signature:  KTableSource(String topic)
focal_class.class_method_signature: KTableSource.get()
focal_class.full_signature: @Override public Processor<K, V> get()
focal_class.identifier: get
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Processor<K, V>
focal_class.signature: Processor<K, V> get()
focal_class.class_method_signature: KTableSource.materialize()
focal_class.full_signature: public void materialize()
focal_class.identifier: materialize
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void materialize()
focal_class.class_method_signature: KTableSource.isMaterialized()
focal_class.full_signature: public boolean isMaterialized()
focal_class.identifier: isMaterialized
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isMaterialized()
focal_class.class_method_signature: KTableSource.enableSendingOldValues()
focal_class.full_signature: public void enableSendingOldValues()
focal_class.identifier: enableSendingOldValues
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void enableSendingOldValues()
focal_method.body: @Override
      public Processor<K, V> get() {
          return materialized ? new MaterializedKTableSourceProcessor() : new KTableSourceProcessor();
      }
focal_method.class_method_signature: KTableSource.get()
focal_method.full_signature: @Override public Processor<K, V> get()
focal_method.identifier: get
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: Processor<K, V>
focal_method.signature: Processor<K, V> get()