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/KTableMapValuesTest.java
test_class.identifier: KTableMapValuesTest
test_case.body: @Test
      public void testValueGetter() throws IOException {
          KStreamBuilder builder = new KStreamBuilder();
  
          String topic1 = "topic1";
          String topic2 = "topic2";
  
          KTableImpl<String, String, String> table1 =
                  (KTableImpl<String, String, String>) builder.table(stringSerde, stringSerde, topic1);
          KTableImpl<String, String, Integer> table2 = (KTableImpl<String, String, Integer>) table1.mapValues(
                  new ValueMapper<String, Integer>() {
                      @Override
                      public Integer apply(String value) {
                          return new Integer(value);
                      }
                  });
          KTableImpl<String, Integer, Integer> table3 = (KTableImpl<String, Integer, Integer>) table2.filter(
                  new Predicate<String, Integer>() {
                      @Override
                      public boolean test(String key, Integer value) {
                          return (value % 2) == 0;
                      }
                  });
          KTableImpl<String, String, String> table4 = (KTableImpl<String, String, String>)
                  table1.through(stringSerde, stringSerde, topic2);
  
          KTableValueGetterSupplier<String, String> getterSupplier1 = table1.valueGetterSupplier();
          KTableValueGetterSupplier<String, Integer> getterSupplier2 = table2.valueGetterSupplier();
          KTableValueGetterSupplier<String, Integer> getterSupplier3 = table3.valueGetterSupplier();
          KTableValueGetterSupplier<String, String> getterSupplier4 = table4.valueGetterSupplier();
  
          driver = new KStreamTestDriver(builder, stateDir, null, null);
  
          KTableValueGetter<String, String> getter1 = getterSupplier1.get();
          getter1.init(driver.context());
          KTableValueGetter<String, Integer> getter2 = getterSupplier2.get();
          getter2.init(driver.context());
          KTableValueGetter<String, Integer> getter3 = getterSupplier3.get();
          getter3.init(driver.context());
          KTableValueGetter<String, String> getter4 = getterSupplier4.get();
          getter4.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"));
  
          assertEquals(new Integer(1), getter2.get("A"));
          assertEquals(new Integer(1), getter2.get("B"));
          assertEquals(new Integer(1), getter2.get("C"));
  
          assertNull(getter3.get("A"));
          assertNull(getter3.get("B"));
          assertNull(getter3.get("C"));
  
          assertEquals("01", getter4.get("A"));
          assertEquals("01", getter4.get("B"));
          assertEquals("01", getter4.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"));
  
          assertEquals(new Integer(2), getter2.get("A"));
          assertEquals(new Integer(2), getter2.get("B"));
          assertEquals(new Integer(1), getter2.get("C"));
  
          assertEquals(new Integer(2), getter3.get("A"));
          assertEquals(new Integer(2), getter3.get("B"));
          assertNull(getter3.get("C"));
  
          assertEquals("02", getter4.get("A"));
          assertEquals("02", getter4.get("B"));
          assertEquals("01", getter4.get("C"));
  
          driver.process(topic1, "A", "03");
  
          assertEquals("03", getter1.get("A"));
          assertEquals("02", getter1.get("B"));
          assertEquals("01", getter1.get("C"));
  
          assertEquals(new Integer(3), getter2.get("A"));
          assertEquals(new Integer(2), getter2.get("B"));
          assertEquals(new Integer(1), getter2.get("C"));
  
          assertNull(getter3.get("A"));
          assertEquals(new Integer(2), getter3.get("B"));
          assertNull(getter3.get("C"));
  
          assertEquals("03", getter4.get("A"));
          assertEquals("02", getter4.get("B"));
          assertEquals("01", getter4.get("C"));
  
          driver.process(topic1, "A", null);
  
          assertNull(getter1.get("A"));
          assertEquals("02", getter1.get("B"));
          assertEquals("01", getter1.get("C"));
  
          assertNull(getter2.get("A"));
          assertEquals(new Integer(2), getter2.get("B"));
          assertEquals(new Integer(1), getter2.get("C"));
  
          assertNull(getter3.get("A"));
          assertEquals(new Integer(2), getter3.get("B"));
          assertNull(getter3.get("C"));
  
          assertNull(getter4.get("A"));
          assertEquals("02", getter4.get("B"));
          assertEquals("01", getter4.get("C"));
      }
test_case.class_method_signature: KTableMapValuesTest.testValueGetter()
test_case.full_signature: @Test public void testValueGetter()
test_case.identifier: testValueGetter
test_case.invocations: table mapValues filter through valueGetterSupplier valueGetterSupplier valueGetterSupplier valueGetterSupplier get init context get init context get init context get init context process process process assertEquals get assertEquals get assertEquals get assertEquals get assertEquals get assertEquals get assertNull get assertNull get assertNull get assertEquals get assertEquals get assertEquals get process process assertEquals get assertEquals get assertEquals get assertEquals get assertEquals get assertEquals get assertEquals get assertEquals get assertNull get assertEquals get assertEquals get assertEquals get process assertEquals get assertEquals get assertEquals get assertEquals get assertEquals get assertEquals get assertNull get assertEquals get assertNull get assertEquals get assertEquals get assertEquals get process assertNull get assertEquals get assertEquals get assertNull get assertEquals get assertEquals get assertNull get assertEquals get assertNull get assertNull get assertEquals get assertEquals get
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testValueGetter()
focal_class.declarator: parent
focal_class.modifier: private final
focal_class.original_string: private final KTableImpl<K, ?, V> parent;
focal_class.type: KTableImpl<K, ?, V>
focal_class.var_name: parent
focal_class.declarator: mapper
focal_class.modifier: private final
focal_class.original_string: private final ValueMapper<V, V1> mapper;
focal_class.type: ValueMapper<V, V1>
focal_class.var_name: mapper
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/KTableMapValues.java
focal_class.identifier: KTableMapValues
focal_class.interfaces: implements KTableProcessorSupplier<K, V, V1>
focal_class.class_method_signature: KTableMapValues.KTableMapValues(KTableImpl<K, ?, V> parent, ValueMapper<V, V1> mapper)
focal_class.full_signature: public  KTableMapValues(KTableImpl<K, ?, V> parent, ValueMapper<V, V1> mapper)
focal_class.identifier: KTableMapValues
focal_class.modifiers: public
focal_class.parameters: (KTableImpl<K, ?, V> parent, ValueMapper<V, V1> mapper)
focal_class.signature:  KTableMapValues(KTableImpl<K, ?, V> parent, ValueMapper<V, V1> mapper)
focal_class.class_method_signature: KTableMapValues.get()
focal_class.full_signature: @Override public Processor<K, Change<V>> get()
focal_class.identifier: get
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Processor<K, Change<V>>
focal_class.signature: Processor<K, Change<V>> get()
focal_class.class_method_signature: KTableMapValues.view()
focal_class.full_signature: @Override public KTableValueGetterSupplier<K, V1> view()
focal_class.identifier: view
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: KTableValueGetterSupplier<K, V1>
focal_class.signature: KTableValueGetterSupplier<K, V1> view()
focal_class.class_method_signature: KTableMapValues.enableSendingOldValues()
focal_class.full_signature: @Override public void enableSendingOldValues()
focal_class.identifier: enableSendingOldValues
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void enableSendingOldValues()
focal_class.class_method_signature: KTableMapValues.computeValue(V value)
focal_class.full_signature: private V1 computeValue(V value)
focal_class.identifier: computeValue
focal_class.modifiers: private
focal_class.parameters: (V value)
focal_class.return: V1
focal_class.signature: V1 computeValue(V value)
focal_method.body: @Override
      public Processor<K, Change<V>> get() {
          return new KTableMapValuesProcessor();
      }
focal_method.class_method_signature: KTableMapValues.get()
focal_method.full_signature: @Override public Processor<K, Change<V>> get()
focal_method.identifier: get
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: Processor<K, Change<V>>
focal_method.signature: Processor<K, Change<V>> get()