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: intSerde = Serdes.Integer()
test_class.modifier: final private
test_class.original_string: final private Serde<Integer> intSerde = Serdes.Integer();
test_class.type: Serde<Integer>
test_class.var_name: intSerde
test_class.file: streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java
test_class.identifier: KStreamImplTest
test_case.body: @Test
      public void testToWithNullValueSerdeDoesntNPE() {
          final KStreamBuilder builder = new KStreamBuilder();
          final KStream<String, String> inputStream = builder.stream(stringSerde, stringSerde, "input");
          inputStream.to(stringSerde, null, "output");
      }
test_case.class_method_signature: KStreamImplTest.testToWithNullValueSerdeDoesntNPE()
test_case.full_signature: @Test public void testToWithNullValueSerdeDoesntNPE()
test_case.identifier: testToWithNullValueSerdeDoesntNPE
test_case.invocations: stream to
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testToWithNullValueSerdeDoesntNPE()
focal_class.declarator: AGGREGATE_NAME = "KSTREAM-AGGREGATE-"
focal_class.modifier: private static final
focal_class.original_string: private static final String AGGREGATE_NAME = "KSTREAM-AGGREGATE-";
focal_class.type: String
focal_class.var_name: AGGREGATE_NAME
focal_class.declarator: BRANCH_NAME = "KSTREAM-BRANCH-"
focal_class.modifier: private static final
focal_class.original_string: private static final String BRANCH_NAME = "KSTREAM-BRANCH-";
focal_class.type: String
focal_class.var_name: BRANCH_NAME
focal_class.declarator: BRANCHCHILD_NAME = "KSTREAM-BRANCHCHILD-"
focal_class.modifier: private static final
focal_class.original_string: private static final String BRANCHCHILD_NAME = "KSTREAM-BRANCHCHILD-";
focal_class.type: String
focal_class.var_name: BRANCHCHILD_NAME
focal_class.declarator: FILTER_NAME = "KSTREAM-FILTER-"
focal_class.modifier: private static final
focal_class.original_string: private static final String FILTER_NAME = "KSTREAM-FILTER-";
focal_class.type: String
focal_class.var_name: FILTER_NAME
focal_class.declarator: FLATMAP_NAME = "KSTREAM-FLATMAP-"
focal_class.modifier: private static final
focal_class.original_string: private static final String FLATMAP_NAME = "KSTREAM-FLATMAP-";
focal_class.type: String
focal_class.var_name: FLATMAP_NAME
focal_class.declarator: FLATMAPVALUES_NAME = "KSTREAM-FLATMAPVALUES-"
focal_class.modifier: private static final
focal_class.original_string: private static final String FLATMAPVALUES_NAME = "KSTREAM-FLATMAPVALUES-";
focal_class.type: String
focal_class.var_name: FLATMAPVALUES_NAME
focal_class.declarator: JOINTHIS_NAME = "KSTREAM-JOINTHIS-"
focal_class.modifier: public static final
focal_class.original_string: public static final String JOINTHIS_NAME = "KSTREAM-JOINTHIS-";
focal_class.type: String
focal_class.var_name: JOINTHIS_NAME
focal_class.declarator: JOINOTHER_NAME = "KSTREAM-JOINOTHER-"
focal_class.modifier: public static final
focal_class.original_string: public static final String JOINOTHER_NAME = "KSTREAM-JOINOTHER-";
focal_class.type: String
focal_class.var_name: JOINOTHER_NAME
focal_class.declarator: LEFTJOIN_NAME = "KSTREAM-LEFTJOIN-"
focal_class.modifier: public static final
focal_class.original_string: public static final String LEFTJOIN_NAME = "KSTREAM-LEFTJOIN-";
focal_class.type: String
focal_class.var_name: LEFTJOIN_NAME
focal_class.declarator: MAP_NAME = "KSTREAM-MAP-"
focal_class.modifier: private static final
focal_class.original_string: private static final String MAP_NAME = "KSTREAM-MAP-";
focal_class.type: String
focal_class.var_name: MAP_NAME
focal_class.declarator: MAPVALUES_NAME = "KSTREAM-MAPVALUES-"
focal_class.modifier: private static final
focal_class.original_string: private static final String MAPVALUES_NAME = "KSTREAM-MAPVALUES-";
focal_class.type: String
focal_class.var_name: MAPVALUES_NAME
focal_class.declarator: MERGE_NAME = "KSTREAM-MERGE-"
focal_class.modifier: public static final
focal_class.original_string: public static final String MERGE_NAME = "KSTREAM-MERGE-";
focal_class.type: String
focal_class.var_name: MERGE_NAME
focal_class.declarator: OUTERTHIS_NAME = "KSTREAM-OUTERTHIS-"
focal_class.modifier: public static final
focal_class.original_string: public static final String OUTERTHIS_NAME = "KSTREAM-OUTERTHIS-";
focal_class.type: String
focal_class.var_name: OUTERTHIS_NAME
focal_class.declarator: OUTEROTHER_NAME = "KSTREAM-OUTEROTHER-"
focal_class.modifier: public static final
focal_class.original_string: public static final String OUTEROTHER_NAME = "KSTREAM-OUTEROTHER-";
focal_class.type: String
focal_class.var_name: OUTEROTHER_NAME
focal_class.declarator: PROCESSOR_NAME = "KSTREAM-PROCESSOR-"
focal_class.modifier: private static final
focal_class.original_string: private static final String PROCESSOR_NAME = "KSTREAM-PROCESSOR-";
focal_class.type: String
focal_class.var_name: PROCESSOR_NAME
focal_class.declarator: PRINTING_NAME = "KSTREAM-PRINTER-"
focal_class.modifier: private static final
focal_class.original_string: private static final String PRINTING_NAME = "KSTREAM-PRINTER-";
focal_class.type: String
focal_class.var_name: PRINTING_NAME
focal_class.declarator: REDUCE_NAME = "KSTREAM-REDUCE-"
focal_class.modifier: private static final
focal_class.original_string: private static final String REDUCE_NAME = "KSTREAM-REDUCE-";
focal_class.type: String
focal_class.var_name: REDUCE_NAME
focal_class.declarator: KEY_SELECT_NAME = "KSTREAM-KEY-SELECT-"
focal_class.modifier: private static final
focal_class.original_string: private static final String KEY_SELECT_NAME = "KSTREAM-KEY-SELECT-";
focal_class.type: String
focal_class.var_name: KEY_SELECT_NAME
focal_class.declarator: SINK_NAME = "KSTREAM-SINK-"
focal_class.modifier: public static final
focal_class.original_string: public static final String SINK_NAME = "KSTREAM-SINK-";
focal_class.type: String
focal_class.var_name: SINK_NAME
focal_class.declarator: SOURCE_NAME = "KSTREAM-SOURCE-"
focal_class.modifier: public static final
focal_class.original_string: public static final String SOURCE_NAME = "KSTREAM-SOURCE-";
focal_class.type: String
focal_class.var_name: SOURCE_NAME
focal_class.declarator: TRANSFORM_NAME = "KSTREAM-TRANSFORM-"
focal_class.modifier: private static final
focal_class.original_string: private static final String TRANSFORM_NAME = "KSTREAM-TRANSFORM-";
focal_class.type: String
focal_class.var_name: TRANSFORM_NAME
focal_class.declarator: TRANSFORMVALUES_NAME = "KSTREAM-TRANSFORMVALUES-"
focal_class.modifier: private static final
focal_class.original_string: private static final String TRANSFORMVALUES_NAME = "KSTREAM-TRANSFORMVALUES-";
focal_class.type: String
focal_class.var_name: TRANSFORMVALUES_NAME
focal_class.declarator: WINDOWED_NAME = "KSTREAM-WINDOWED-"
focal_class.modifier: private static final
focal_class.original_string: private static final String WINDOWED_NAME = "KSTREAM-WINDOWED-";
focal_class.type: String
focal_class.var_name: WINDOWED_NAME
focal_class.declarator: FOREACH_NAME = "KSTREAM-FOREACH-"
focal_class.modifier: private static final
focal_class.original_string: private static final String FOREACH_NAME = "KSTREAM-FOREACH-";
focal_class.type: String
focal_class.var_name: FOREACH_NAME
focal_class.file: streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
focal_class.identifier: KStreamImpl
focal_class.interfaces: implements KStream<K, V>
focal_class.class_method_signature: KStreamImpl.KStreamImpl(KStreamBuilder topology, String name, Set<String> sourceNodes)
focal_class.full_signature: public  KStreamImpl(KStreamBuilder topology, String name, Set<String> sourceNodes)
focal_class.identifier: KStreamImpl
focal_class.modifiers: public
focal_class.parameters: (KStreamBuilder topology, String name, Set<String> sourceNodes)
focal_class.signature:  KStreamImpl(KStreamBuilder topology, String name, Set<String> sourceNodes)
focal_class.class_method_signature: KStreamImpl.filter(Predicate<K, V> predicate)
focal_class.full_signature: @Override public KStream<K, V> filter(Predicate<K, V> predicate)
focal_class.identifier: filter
focal_class.modifiers: @Override public
focal_class.parameters: (Predicate<K, V> predicate)
focal_class.return: KStream<K, V>
focal_class.signature: KStream<K, V> filter(Predicate<K, V> predicate)
focal_class.class_method_signature: KStreamImpl.filterNot(final Predicate<K, V> predicate)
focal_class.full_signature: @Override public KStream<K, V> filterNot(final Predicate<K, V> predicate)
focal_class.identifier: filterNot
focal_class.modifiers: @Override public
focal_class.parameters: (final Predicate<K, V> predicate)
focal_class.return: KStream<K, V>
focal_class.signature: KStream<K, V> filterNot(final Predicate<K, V> predicate)
focal_class.class_method_signature: KStreamImpl.selectKey(final KeyValueMapper<K, V, K1> mapper)
focal_class.full_signature: @Override @SuppressWarnings("unchecked") public KStream<K1, V> selectKey(final KeyValueMapper<K, V, K1> mapper)
focal_class.identifier: selectKey
focal_class.modifiers: @Override @SuppressWarnings("unchecked") public
focal_class.parameters: (final KeyValueMapper<K, V, K1> mapper)
focal_class.return: KStream<K1, V>
focal_class.signature: KStream<K1, V> selectKey(final KeyValueMapper<K, V, K1> mapper)
focal_class.class_method_signature: KStreamImpl.map(KeyValueMapper<K, V, KeyValue<K1, V1>> mapper)
focal_class.full_signature: @Override public KStream<K1, V1> map(KeyValueMapper<K, V, KeyValue<K1, V1>> mapper)
focal_class.identifier: map
focal_class.modifiers: @Override public
focal_class.parameters: (KeyValueMapper<K, V, KeyValue<K1, V1>> mapper)
focal_class.return: KStream<K1, V1>
focal_class.signature: KStream<K1, V1> map(KeyValueMapper<K, V, KeyValue<K1, V1>> mapper)
focal_class.class_method_signature: KStreamImpl.mapValues(ValueMapper<V, V1> mapper)
focal_class.full_signature: @Override public KStream<K, V1> mapValues(ValueMapper<V, V1> mapper)
focal_class.identifier: mapValues
focal_class.modifiers: @Override public
focal_class.parameters: (ValueMapper<V, V1> mapper)
focal_class.return: KStream<K, V1>
focal_class.signature: KStream<K, V1> mapValues(ValueMapper<V, V1> mapper)
focal_class.class_method_signature: KStreamImpl.print()
focal_class.full_signature: @Override public void print()
focal_class.identifier: print
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void print()
focal_class.class_method_signature: KStreamImpl.print(Serde<K> keySerde, Serde<V> valSerde)
focal_class.full_signature: @Override public void print(Serde<K> keySerde, Serde<V> valSerde)
focal_class.identifier: print
focal_class.modifiers: @Override public
focal_class.parameters: (Serde<K> keySerde, Serde<V> valSerde)
focal_class.return: void
focal_class.signature: void print(Serde<K> keySerde, Serde<V> valSerde)
focal_class.class_method_signature: KStreamImpl.writeAsText(String filePath)
focal_class.full_signature: @Override public void writeAsText(String filePath)
focal_class.identifier: writeAsText
focal_class.modifiers: @Override public
focal_class.parameters: (String filePath)
focal_class.return: void
focal_class.signature: void writeAsText(String filePath)
focal_class.class_method_signature: KStreamImpl.writeAsText(String filePath, Serde<K> keySerde, Serde<V> valSerde)
focal_class.full_signature: @Override public void writeAsText(String filePath, Serde<K> keySerde, Serde<V> valSerde)
focal_class.identifier: writeAsText
focal_class.modifiers: @Override public
focal_class.parameters: (String filePath, Serde<K> keySerde, Serde<V> valSerde)
focal_class.return: void
focal_class.signature: void writeAsText(String filePath, Serde<K> keySerde, Serde<V> valSerde)
focal_class.class_method_signature: KStreamImpl.flatMap(KeyValueMapper<K, V, Iterable<KeyValue<K1, V1>>> mapper)
focal_class.full_signature: @Override public KStream<K1, V1> flatMap(KeyValueMapper<K, V, Iterable<KeyValue<K1, V1>>> mapper)
focal_class.identifier: flatMap
focal_class.modifiers: @Override public
focal_class.parameters: (KeyValueMapper<K, V, Iterable<KeyValue<K1, V1>>> mapper)
focal_class.return: KStream<K1, V1>
focal_class.signature: KStream<K1, V1> flatMap(KeyValueMapper<K, V, Iterable<KeyValue<K1, V1>>> mapper)
focal_class.class_method_signature: KStreamImpl.flatMapValues(ValueMapper<V, Iterable<V1>> mapper)
focal_class.full_signature: @Override public KStream<K, V1> flatMapValues(ValueMapper<V, Iterable<V1>> mapper)
focal_class.identifier: flatMapValues
focal_class.modifiers: @Override public
focal_class.parameters: (ValueMapper<V, Iterable<V1>> mapper)
focal_class.return: KStream<K, V1>
focal_class.signature: KStream<K, V1> flatMapValues(ValueMapper<V, Iterable<V1>> mapper)
focal_class.class_method_signature: KStreamImpl.branch(Predicate<K, V>... predicates)
focal_class.full_signature: @Override @SuppressWarnings("unchecked") public KStream<K, V>[] branch(Predicate<K, V>... predicates)
focal_class.identifier: branch
focal_class.modifiers: @Override @SuppressWarnings("unchecked") public
focal_class.parameters: (Predicate<K, V>... predicates)
focal_class.return: KStream<K, V>[]
focal_class.signature: KStream<K, V>[] branch(Predicate<K, V>... predicates)
focal_class.class_method_signature: KStreamImpl.merge(KStreamBuilder topology, KStream<K, V>[] streams)
focal_class.full_signature: public static KStream<K, V> merge(KStreamBuilder topology, KStream<K, V>[] streams)
focal_class.identifier: merge
focal_class.modifiers: public static
focal_class.parameters: (KStreamBuilder topology, KStream<K, V>[] streams)
focal_class.return: KStream<K, V>
focal_class.signature: KStream<K, V> merge(KStreamBuilder topology, KStream<K, V>[] streams)
focal_class.class_method_signature: KStreamImpl.through(Serde<K> keySerde, Serde<V> valSerde, StreamPartitioner<K, V> partitioner, String topic)
focal_class.full_signature: @Override public KStream<K, V> through(Serde<K> keySerde, Serde<V> valSerde, StreamPartitioner<K, V> partitioner, String topic)
focal_class.identifier: through
focal_class.modifiers: @Override public
focal_class.parameters: (Serde<K> keySerde, Serde<V> valSerde, StreamPartitioner<K, V> partitioner, String topic)
focal_class.return: KStream<K, V>
focal_class.signature: KStream<K, V> through(Serde<K> keySerde, Serde<V> valSerde, StreamPartitioner<K, V> partitioner, String topic)
focal_class.class_method_signature: KStreamImpl.foreach(ForeachAction<K, V> action)
focal_class.full_signature: @Override public void foreach(ForeachAction<K, V> action)
focal_class.identifier: foreach
focal_class.modifiers: @Override public
focal_class.parameters: (ForeachAction<K, V> action)
focal_class.return: void
focal_class.signature: void foreach(ForeachAction<K, V> action)
focal_class.class_method_signature: KStreamImpl.through(Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.full_signature: @Override public KStream<K, V> through(Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.identifier: through
focal_class.modifiers: @Override public
focal_class.parameters: (Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.return: KStream<K, V>
focal_class.signature: KStream<K, V> through(Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.class_method_signature: KStreamImpl.through(StreamPartitioner<K, V> partitioner, String topic)
focal_class.full_signature: @Override public KStream<K, V> through(StreamPartitioner<K, V> partitioner, String topic)
focal_class.identifier: through
focal_class.modifiers: @Override public
focal_class.parameters: (StreamPartitioner<K, V> partitioner, String topic)
focal_class.return: KStream<K, V>
focal_class.signature: KStream<K, V> through(StreamPartitioner<K, V> partitioner, String topic)
focal_class.class_method_signature: KStreamImpl.through(String topic)
focal_class.full_signature: @Override public KStream<K, V> through(String topic)
focal_class.identifier: through
focal_class.modifiers: @Override public
focal_class.parameters: (String topic)
focal_class.return: KStream<K, V>
focal_class.signature: KStream<K, V> through(String topic)
focal_class.class_method_signature: KStreamImpl.to(String topic)
focal_class.full_signature: @Override public void to(String topic)
focal_class.identifier: to
focal_class.modifiers: @Override public
focal_class.parameters: (String topic)
focal_class.return: void
focal_class.signature: void to(String topic)
focal_class.class_method_signature: KStreamImpl.to(StreamPartitioner<K, V> partitioner, String topic)
focal_class.full_signature: @Override public void to(StreamPartitioner<K, V> partitioner, String topic)
focal_class.identifier: to
focal_class.modifiers: @Override public
focal_class.parameters: (StreamPartitioner<K, V> partitioner, String topic)
focal_class.return: void
focal_class.signature: void to(StreamPartitioner<K, V> partitioner, String topic)
focal_class.class_method_signature: KStreamImpl.to(Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.full_signature: @Override public void to(Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.identifier: to
focal_class.modifiers: @Override public
focal_class.parameters: (Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.return: void
focal_class.signature: void to(Serde<K> keySerde, Serde<V> valSerde, String topic)
focal_class.class_method_signature: KStreamImpl.to(Serde<K> keySerde, Serde<V> valSerde, StreamPartitioner<K, V> partitioner, String topic)
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public void to(Serde<K> keySerde, Serde<V> valSerde, StreamPartitioner<K, V> partitioner, String topic)
focal_class.identifier: to
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: (Serde<K> keySerde, Serde<V> valSerde, StreamPartitioner<K, V> partitioner, String topic)
focal_class.return: void
focal_class.signature: void to(Serde<K> keySerde, Serde<V> valSerde, StreamPartitioner<K, V> partitioner, String topic)
focal_class.class_method_signature: KStreamImpl.transform(TransformerSupplier<K, V, KeyValue<K1, V1>> transformerSupplier, String... stateStoreNames)
focal_class.full_signature: @Override public KStream<K1, V1> transform(TransformerSupplier<K, V, KeyValue<K1, V1>> transformerSupplier, String... stateStoreNames)
focal_class.identifier: transform
focal_class.modifiers: @Override public
focal_class.parameters: (TransformerSupplier<K, V, KeyValue<K1, V1>> transformerSupplier, String... stateStoreNames)
focal_class.return: KStream<K1, V1>
focal_class.signature: KStream<K1, V1> transform(TransformerSupplier<K, V, KeyValue<K1, V1>> transformerSupplier, String... stateStoreNames)
focal_class.class_method_signature: KStreamImpl.transformValues(ValueTransformerSupplier<V, V1> valueTransformerSupplier, String... stateStoreNames)
focal_class.full_signature: @Override public KStream<K, V1> transformValues(ValueTransformerSupplier<V, V1> valueTransformerSupplier, String... stateStoreNames)
focal_class.identifier: transformValues
focal_class.modifiers: @Override public
focal_class.parameters: (ValueTransformerSupplier<V, V1> valueTransformerSupplier, String... stateStoreNames)
focal_class.return: KStream<K, V1>
focal_class.signature: KStream<K, V1> transformValues(ValueTransformerSupplier<V, V1> valueTransformerSupplier, String... stateStoreNames)
focal_class.class_method_signature: KStreamImpl.process(final ProcessorSupplier<K, V> processorSupplier, String... stateStoreNames)
focal_class.full_signature: @Override public void process(final ProcessorSupplier<K, V> processorSupplier, String... stateStoreNames)
focal_class.identifier: process
focal_class.modifiers: @Override public
focal_class.parameters: (final ProcessorSupplier<K, V> processorSupplier, String... stateStoreNames)
focal_class.return: void
focal_class.signature: void process(final ProcessorSupplier<K, V> processorSupplier, String... stateStoreNames)
focal_class.class_method_signature: KStreamImpl.join(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde)
focal_class.full_signature: @Override public KStream<K, R> join(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde)
focal_class.identifier: join
focal_class.modifiers: @Override public
focal_class.parameters: (
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde)
focal_class.return: KStream<K, R>
focal_class.signature: KStream<K, R> join(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde)
focal_class.class_method_signature: KStreamImpl.join(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.full_signature: @Override public KStream<K, R> join(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.identifier: join
focal_class.modifiers: @Override public
focal_class.parameters: (
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.return: KStream<K, R>
focal_class.signature: KStream<K, R> join(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.class_method_signature: KStreamImpl.outerJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde)
focal_class.full_signature: @Override public KStream<K, R> outerJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde)
focal_class.identifier: outerJoin
focal_class.modifiers: @Override public
focal_class.parameters: (
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde)
focal_class.return: KStream<K, R>
focal_class.signature: KStream<K, R> outerJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde)
focal_class.class_method_signature: KStreamImpl.outerJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.full_signature: @Override public KStream<K, R> outerJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.identifier: outerJoin
focal_class.modifiers: @Override public
focal_class.parameters: (
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.return: KStream<K, R>
focal_class.signature: KStream<K, R> outerJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.class_method_signature: KStreamImpl.join(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde,
              boolean outer)
focal_class.full_signature: @SuppressWarnings("unchecked") private KStream<K, R> join(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde,
              boolean outer)
focal_class.identifier: join
focal_class.modifiers: @SuppressWarnings("unchecked") private
focal_class.parameters: (
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde,
              boolean outer)
focal_class.return: KStream<K, R>
focal_class.signature: KStream<K, R> join(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V> thisValueSerde,
              Serde<V1> otherValueSerde,
              boolean outer)
focal_class.class_method_signature: KStreamImpl.leftJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V1> otherValueSerde)
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public KStream<K, R> leftJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V1> otherValueSerde)
focal_class.identifier: leftJoin
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: (
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V1> otherValueSerde)
focal_class.return: KStream<K, R>
focal_class.signature: KStream<K, R> leftJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows,
              Serde<K> keySerde,
              Serde<V1> otherValueSerde)
focal_class.class_method_signature: KStreamImpl.leftJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.full_signature: @Override public KStream<K, R> leftJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.identifier: leftJoin
focal_class.modifiers: @Override public
focal_class.parameters: (
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.return: KStream<K, R>
focal_class.signature: KStream<K, R> leftJoin(
              KStream<K, V1> other,
              ValueJoiner<V, V1, R> joiner,
              JoinWindows windows)
focal_class.class_method_signature: KStreamImpl.leftJoin(KTable<K, V1> other, ValueJoiner<V, V1, R> joiner)
focal_class.full_signature: @SuppressWarnings("unchecked") @Override public KStream<K, R> leftJoin(KTable<K, V1> other, ValueJoiner<V, V1, R> joiner)
focal_class.identifier: leftJoin
focal_class.modifiers: @SuppressWarnings("unchecked") @Override public
focal_class.parameters: (KTable<K, V1> other, ValueJoiner<V, V1, R> joiner)
focal_class.return: KStream<K, R>
focal_class.signature: KStream<K, R> leftJoin(KTable<K, V1> other, ValueJoiner<V, V1, R> joiner)
focal_class.class_method_signature: KStreamImpl.reduceByKey(Reducer<V> reducer,
                                                                   Windows<W> windows,
                                                                   Serde<K> keySerde,
                                                                   Serde<V> aggValueSerde)
focal_class.full_signature: @Override public KTable<Windowed<K>, V> reduceByKey(Reducer<V> reducer,
                                                                   Windows<W> windows,
                                                                   Serde<K> keySerde,
                                                                   Serde<V> aggValueSerde)
focal_class.identifier: reduceByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Reducer<V> reducer,
                                                                   Windows<W> windows,
                                                                   Serde<K> keySerde,
                                                                   Serde<V> aggValueSerde)
focal_class.return: KTable<Windowed<K>, V>
focal_class.signature: KTable<Windowed<K>, V> reduceByKey(Reducer<V> reducer,
                                                                   Windows<W> windows,
                                                                   Serde<K> keySerde,
                                                                   Serde<V> aggValueSerde)
focal_class.class_method_signature: KStreamImpl.reduceByKey(Reducer<V> reducer,
                                                                   Windows<W> windows)
focal_class.full_signature: @Override public KTable<Windowed<K>, V> reduceByKey(Reducer<V> reducer,
                                                                   Windows<W> windows)
focal_class.identifier: reduceByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Reducer<V> reducer,
                                                                   Windows<W> windows)
focal_class.return: KTable<Windowed<K>, V>
focal_class.signature: KTable<Windowed<K>, V> reduceByKey(Reducer<V> reducer,
                                                                   Windows<W> windows)
focal_class.class_method_signature: KStreamImpl.reduceByKey(Reducer<V> reducer,
                                      Serde<K> keySerde,
                                      Serde<V> aggValueSerde,
                                      String name)
focal_class.full_signature: @Override public KTable<K, V> reduceByKey(Reducer<V> reducer,
                                      Serde<K> keySerde,
                                      Serde<V> aggValueSerde,
                                      String name)
focal_class.identifier: reduceByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Reducer<V> reducer,
                                      Serde<K> keySerde,
                                      Serde<V> aggValueSerde,
                                      String name)
focal_class.return: KTable<K, V>
focal_class.signature: KTable<K, V> reduceByKey(Reducer<V> reducer,
                                      Serde<K> keySerde,
                                      Serde<V> aggValueSerde,
                                      String name)
focal_class.class_method_signature: KStreamImpl.reduceByKey(Reducer<V> reducer, String name)
focal_class.full_signature: @Override public KTable<K, V> reduceByKey(Reducer<V> reducer, String name)
focal_class.identifier: reduceByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Reducer<V> reducer, String name)
focal_class.return: KTable<K, V>
focal_class.signature: KTable<K, V> reduceByKey(Reducer<V> reducer, String name)
focal_class.class_method_signature: KStreamImpl.aggregateByKey(Initializer<T> initializer,
                                                                         Aggregator<K, V, T> aggregator,
                                                                         Windows<W> windows,
                                                                         Serde<K> keySerde,
                                                                         Serde<T> aggValueSerde)
focal_class.full_signature: @Override public KTable<Windowed<K>, T> aggregateByKey(Initializer<T> initializer,
                                                                         Aggregator<K, V, T> aggregator,
                                                                         Windows<W> windows,
                                                                         Serde<K> keySerde,
                                                                         Serde<T> aggValueSerde)
focal_class.identifier: aggregateByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Initializer<T> initializer,
                                                                         Aggregator<K, V, T> aggregator,
                                                                         Windows<W> windows,
                                                                         Serde<K> keySerde,
                                                                         Serde<T> aggValueSerde)
focal_class.return: KTable<Windowed<K>, T>
focal_class.signature: KTable<Windowed<K>, T> aggregateByKey(Initializer<T> initializer,
                                                                         Aggregator<K, V, T> aggregator,
                                                                         Windows<W> windows,
                                                                         Serde<K> keySerde,
                                                                         Serde<T> aggValueSerde)
focal_class.class_method_signature: KStreamImpl.aggregateByKey(Initializer<T> initializer,
                                                                         Aggregator<K, V, T> aggregator,
                                                                         Windows<W> windows)
focal_class.full_signature: @Override public KTable<Windowed<K>, T> aggregateByKey(Initializer<T> initializer,
                                                                         Aggregator<K, V, T> aggregator,
                                                                         Windows<W> windows)
focal_class.identifier: aggregateByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Initializer<T> initializer,
                                                                         Aggregator<K, V, T> aggregator,
                                                                         Windows<W> windows)
focal_class.return: KTable<Windowed<K>, T>
focal_class.signature: KTable<Windowed<K>, T> aggregateByKey(Initializer<T> initializer,
                                                                         Aggregator<K, V, T> aggregator,
                                                                         Windows<W> windows)
focal_class.class_method_signature: KStreamImpl.aggregateByKey(Initializer<T> initializer,
                                             Aggregator<K, V, T> aggregator,
                                             Serde<K> keySerde,
                                             Serde<T> aggValueSerde,
                                             String name)
focal_class.full_signature: @Override public KTable<K, T> aggregateByKey(Initializer<T> initializer,
                                             Aggregator<K, V, T> aggregator,
                                             Serde<K> keySerde,
                                             Serde<T> aggValueSerde,
                                             String name)
focal_class.identifier: aggregateByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Initializer<T> initializer,
                                             Aggregator<K, V, T> aggregator,
                                             Serde<K> keySerde,
                                             Serde<T> aggValueSerde,
                                             String name)
focal_class.return: KTable<K, T>
focal_class.signature: KTable<K, T> aggregateByKey(Initializer<T> initializer,
                                             Aggregator<K, V, T> aggregator,
                                             Serde<K> keySerde,
                                             Serde<T> aggValueSerde,
                                             String name)
focal_class.class_method_signature: KStreamImpl.aggregateByKey(Initializer<T> initializer,
                                             Aggregator<K, V, T> aggregator,
                                             String name)
focal_class.full_signature: @Override public KTable<K, T> aggregateByKey(Initializer<T> initializer,
                                             Aggregator<K, V, T> aggregator,
                                             String name)
focal_class.identifier: aggregateByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Initializer<T> initializer,
                                             Aggregator<K, V, T> aggregator,
                                             String name)
focal_class.return: KTable<K, T>
focal_class.signature: KTable<K, T> aggregateByKey(Initializer<T> initializer,
                                             Aggregator<K, V, T> aggregator,
                                             String name)
focal_class.class_method_signature: KStreamImpl.countByKey(Windows<W> windows,
                                                                     Serde<K> keySerde)
focal_class.full_signature: @Override public KTable<Windowed<K>, Long> countByKey(Windows<W> windows,
                                                                     Serde<K> keySerde)
focal_class.identifier: countByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Windows<W> windows,
                                                                     Serde<K> keySerde)
focal_class.return: KTable<Windowed<K>, Long>
focal_class.signature: KTable<Windowed<K>, Long> countByKey(Windows<W> windows,
                                                                     Serde<K> keySerde)
focal_class.class_method_signature: KStreamImpl.countByKey(Windows<W> windows)
focal_class.full_signature: @Override public KTable<Windowed<K>, Long> countByKey(Windows<W> windows)
focal_class.identifier: countByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Windows<W> windows)
focal_class.return: KTable<Windowed<K>, Long>
focal_class.signature: KTable<Windowed<K>, Long> countByKey(Windows<W> windows)
focal_class.class_method_signature: KStreamImpl.countByKey(Serde<K> keySerde, String name)
focal_class.full_signature: @Override public KTable<K, Long> countByKey(Serde<K> keySerde, String name)
focal_class.identifier: countByKey
focal_class.modifiers: @Override public
focal_class.parameters: (Serde<K> keySerde, String name)
focal_class.return: KTable<K, Long>
focal_class.signature: KTable<K, Long> countByKey(Serde<K> keySerde, String name)
focal_class.class_method_signature: KStreamImpl.countByKey(String name)
focal_class.full_signature: @Override public KTable<K, Long> countByKey(String name)
focal_class.identifier: countByKey
focal_class.modifiers: @Override public
focal_class.parameters: (String name)
focal_class.return: KTable<K, Long>
focal_class.signature: KTable<K, Long> countByKey(String name)
focal_class.superclass: extends AbstractStream<K>
focal_method.body: @Override
      public void to(String topic) {
          to(null, null, null, topic);
      }
focal_method.class_method_signature: KStreamImpl.to(String topic)
focal_method.full_signature: @Override public void to(String topic)
focal_method.identifier: to
focal_method.invocations: to
focal_method.modifiers: @Override public
focal_method.parameters: (String topic)
focal_method.return: void
focal_method.signature: void to(String topic)