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.file: streams/src/test/java/org/apache/kafka/streams/kstream/KStreamBuilderTest.java
test_class.identifier: KStreamBuilderTest
test_case.body: @Test(expected = TopologyBuilderException.class)
      public void testFrom() {
          final KStreamBuilder builder = new KStreamBuilder();
  
          builder.stream("topic-1", "topic-2");
  
          builder.addSource(KStreamImpl.SOURCE_NAME + "0000000000", "topic-3");
      }
test_case.class_method_signature: KStreamBuilderTest.testFrom()
test_case.full_signature: @Test(expected = TopologyBuilderException.class) public void testFrom()
test_case.identifier: testFrom
test_case.invocations: stream addSource
test_case.modifiers: @Test(expected = TopologyBuilderException.class) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testFrom()
focal_class.declarator: index = new AtomicInteger(0)
focal_class.modifier: private final
focal_class.original_string: private final AtomicInteger index = new AtomicInteger(0);
focal_class.type: AtomicInteger
focal_class.var_name: index
focal_class.file: streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java
focal_class.identifier: KStreamBuilder
focal_class.class_method_signature: KStreamBuilder.KStreamBuilder()
focal_class.full_signature: public  KStreamBuilder()
focal_class.identifier: KStreamBuilder
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.signature:  KStreamBuilder()
focal_class.class_method_signature: KStreamBuilder.stream(String... topics)
focal_class.full_signature: public KStream<K, V> stream(String... topics)
focal_class.identifier: stream
focal_class.modifiers: public
focal_class.parameters: (String... topics)
focal_class.return: KStream<K, V>
focal_class.signature: KStream<K, V> stream(String... topics)
focal_class.class_method_signature: KStreamBuilder.stream(Serde<K> keySerde, Serde<V> valSerde, String... topics)
focal_class.full_signature: public KStream<K, V> stream(Serde<K> keySerde, Serde<V> valSerde, String... topics)
focal_class.identifier: stream
focal_class.modifiers: public
focal_class.parameters: (Serde<K> keySerde, Serde<V> valSerde, String... topics)
focal_class.return: KStream<K, V>
focal_class.signature: KStream<K, V> stream(Serde<K> keySerde, Serde<V> valSerde, String... topics)
focal_class.class_method_signature: KStreamBuilder.table(String topic)
focal_class.full_signature: public KTable<K, V> table(String topic)
focal_class.identifier: table
focal_class.modifiers: public
focal_class.parameters: (String topic)
focal_class.return: KTable<K, V>
focal_class.signature: KTable<K, V> table(String topic)
focal_class.class_method_signature: KStreamBuilder.table(Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.full_signature: public KTable<K, V> table(Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.identifier: table
focal_class.modifiers: public
focal_class.parameters: (Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.return: KTable<K, V>
focal_class.signature: KTable<K, V> table(Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.class_method_signature: KStreamBuilder.merge(KStream<K, V>... streams)
focal_class.full_signature: public KStream<K, V> merge(KStream<K, V>... streams)
focal_class.identifier: merge
focal_class.modifiers: public
focal_class.parameters: (KStream<K, V>... streams)
focal_class.return: KStream<K, V>
focal_class.signature: KStream<K, V> merge(KStream<K, V>... streams)
focal_class.class_method_signature: KStreamBuilder.newName(String prefix)
focal_class.full_signature: public String newName(String prefix)
focal_class.identifier: newName
focal_class.modifiers: public
focal_class.parameters: (String prefix)
focal_class.return: String
focal_class.signature: String newName(String prefix)
focal_class.superclass: extends TopologyBuilder
focal_method.body: public <K, V> KStream<K, V> stream(String... topics) {
          return stream(null, null, topics);
      }
focal_method.class_method_signature: KStreamBuilder.stream(String... topics)
focal_method.full_signature: public KStream<K, V> stream(String... topics)
focal_method.identifier: stream
focal_method.invocations: stream
focal_method.modifiers: public
focal_method.parameters: (String... topics)
focal_method.return: KStream<K, V>
focal_method.signature: KStream<K, V> stream(String... topics)