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 testSendingOldValue() throws IOException {
          KStreamBuilder builder = new KStreamBuilder();
  
          String topic1 = "topic1";
  
          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);
                      }
                  });
  
          table2.enableSendingOldValues();
  
          MockProcessorSupplier<String, Integer> proc = new MockProcessorSupplier<>();
  
          builder.addProcessor("proc", proc, table2.name);
  
          driver = new KStreamTestDriver(builder, stateDir, null, null);
  
          assertTrue(table1.sendingOldValueEnabled());
          assertTrue(table2.sendingOldValueEnabled());
  
          driver.process(topic1, "A", "01");
          driver.process(topic1, "B", "01");
          driver.process(topic1, "C", "01");
  
          proc.checkAndClearProcessResult("A:(1<-null)", "B:(1<-null)", "C:(1<-null)");
  
          driver.process(topic1, "A", "02");
          driver.process(topic1, "B", "02");
  
          proc.checkAndClearProcessResult("A:(2<-1)", "B:(2<-1)");
  
          driver.process(topic1, "A", "03");
  
          proc.checkAndClearProcessResult("A:(3<-2)");
  
          driver.process(topic1, "A", null);
  
          proc.checkAndClearProcessResult("A:(null<-3)");
      }
test_case.class_method_signature: KTableMapValuesTest.testSendingOldValue()
test_case.full_signature: @Test public void testSendingOldValue()
test_case.identifier: testSendingOldValue
test_case.invocations: table mapValues enableSendingOldValues addProcessor assertTrue sendingOldValueEnabled assertTrue sendingOldValueEnabled process process process checkAndClearProcessResult process process checkAndClearProcessResult process checkAndClearProcessResult process checkAndClearProcessResult
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSendingOldValue()
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 void enableSendingOldValues() {
          parent.enableSendingOldValues();
          sendOldValues = true;
      }
focal_method.class_method_signature: KTableMapValues.enableSendingOldValues()
focal_method.full_signature: @Override public void enableSendingOldValues()
focal_method.identifier: enableSendingOldValues
focal_method.invocations: enableSendingOldValues
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: void
focal_method.signature: void enableSendingOldValues()