@Test(expected = NullPointerException.class) public void shouldNotAllowNullPredicateOnFilter() throws Exception { table.filter(null); }
@Override public KTable<K, V> filter(final Predicate<? super K, ? super V> predicate) { return filter(predicate, (String) null); }
KTableImpl extends AbstractStream<K> implements KTable<K, V> { @Override public KTable<K, V> filter(final Predicate<? super K, ? super V> predicate) { return filter(predicate, (String) null); } }
KTableImpl extends AbstractStream<K> implements KTable<K, V> { @Override public KTable<K, V> filter(final Predicate<? super K, ? super V> predicate) { return filter(predicate, (String) null); } KTableImpl(KStreamBuilder topology,
                      String name,
                      ProcessorSupplier<?, ?> processorSupplier,
                      Set<String> sourceNodes,
                      final String queryableStoreName,
                      boolean isQueryable);  KTableImpl(KStreamBuilder topology,
                      String name,
                      ProcessorSupplier<?, ?> processorSupplier,
                      final Serde<K> keySerde,
                      final Serde<V> valSerde,
                      Set<String> sourceNodes,
                      final String queryableStoreName,
                      boolean isQueryable); }
KTableImpl extends AbstractStream<K> implements KTable<K, V> { @Override public KTable<K, V> filter(final Predicate<? super K, ? super V> predicate) { return filter(predicate, (String) null); } KTableImpl(KStreamBuilder topology,
                      String name,
                      ProcessorSupplier<?, ?> processorSupplier,
                      Set<String> sourceNodes,
                      final String queryableStoreName,
                      boolean isQueryable);  KTableImpl(KStreamBuilder topology,
                      String name,
                      ProcessorSupplier<?, ?> processorSupplier,
                      final Serde<K> keySerde,
                      final Serde<V> valSerde,
                      Set<String> sourceNodes,
                      final String queryableStoreName,
                      boolean isQueryable); @Override String queryableStoreName(); @Override KTable<K, V> filter(final Predicate<? super K, ? super V> predicate); @Override KTable<K, V> filter(final Predicate<? super K, ? super V> predicate, final String queryableStoreName); @Override KTable<K, V> filter(final Predicate<? super K, ? super V> predicate, final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V> filterNot(final Predicate<? super K, ? super V> predicate); @Override KTable<K, V> filterNot(final Predicate<? super K, ? super V> predicate, final String queryableStoreName); @Override KTable<K, V> filterNot(final Predicate<? super K, ? super V> predicate, final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V1> mapValues(final ValueMapper<? super V, ? extends V1> mapper); @Override KTable<K, V1> mapValues(final ValueMapper<? super V, ? extends V1> mapper,
                                        final Serde<V1> valueSerde,
                                        final String queryableStoreName); @Override KTable<K, V1> mapValues(final ValueMapper<? super V, ? extends V1> mapper,
                                         final Serde<V1> valueSerde,
                                         final StateStoreSupplier<KeyValueStore> storeSupplier); @Override void print(); @Override void print(String streamName); @Override void print(Serde<K> keySerde, Serde<V> valSerde); @Override void print(Serde<K> keySerde, Serde<V> valSerde, String streamName); @Override void writeAsText(String filePath); @Override void writeAsText(String filePath, String streamName); @Override void writeAsText(String filePath, Serde<K> keySerde, Serde<V> valSerde); @Override void writeAsText(String filePath, String streamName, Serde<K> keySerde, Serde<V> valSerde); @Override void foreach(final ForeachAction<? super K, ? super V> action); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic,
                                final String queryableStoreName); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic,
                                final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final String topic,
                                final String queryableStoreName); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final String topic,
                                final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final String topic); @Override KTable<K, V> through(final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic,
                                final String queryableStoreName); @Override KTable<K, V> through(final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic,
                                final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V> through(final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic); @Override KTable<K, V> through(final String topic,
                                final String queryableStoreName); @Override KTable<K, V> through(final String topic,
                                final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V> through(final String topic); @Override void to(String topic); @Override void to(StreamPartitioner<? super K, ? super V> partitioner, String topic); @Override void to(Serde<K> keySerde, Serde<V> valSerde, String topic); @Override void to(Serde<K> keySerde, Serde<V> valSerde, StreamPartitioner<? super K, ? super V> partitioner, String topic); @Override KStream<K, V> toStream(); @Override KStream<K1, V> toStream(KeyValueMapper<? super K, ? super V, ? extends K1> mapper); @Override KTable<K, R> join(final KTable<K, V1> other,
                                     final ValueJoiner<? super V, ? super V1, ? extends R> joiner); @Override KTable<K, R> join(final KTable<K, V1> other,
                                     final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                     final Serde<R> joinSerde,
                                     final String queryableStoreName); @Override KTable<K, R> join(final KTable<K, V1> other,
                                     final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                     final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, R> outerJoin(final KTable<K, V1> other,
                                          final ValueJoiner<? super V, ? super V1, ? extends R> joiner); @Override KTable<K, R> outerJoin(final KTable<K, V1> other,
                                          final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                          final Serde<R> joinSerde,
                                          final String queryableStoreName); @Override KTable<K, R> outerJoin(final KTable<K, V1> other,
                                          final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                          final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, R> leftJoin(final KTable<K, V1> other,
                                         final ValueJoiner<? super V, ? super V1, ? extends R> joiner); @Override KTable<K, R> leftJoin(final KTable<K, V1> other,
                                         final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                         final Serde<R> joinSerde,
                                         final String queryableStoreName); @Override KTable<K, R> leftJoin(final KTable<K, V1> other,
                                         final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                         final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KGroupedTable<K1, V1> groupBy(KeyValueMapper<? super K, ? super V, KeyValue<K1, V1>> selector,
                                                  Serde<K1> keySerde,
                                                  Serde<V1> valueSerde); @Override KGroupedTable<K1, V1> groupBy(KeyValueMapper<? super K, ? super V, KeyValue<K1, V1>> selector); }
KTableImpl extends AbstractStream<K> implements KTable<K, V> { @Override public KTable<K, V> filter(final Predicate<? super K, ? super V> predicate) { return filter(predicate, (String) null); } KTableImpl(KStreamBuilder topology,
                      String name,
                      ProcessorSupplier<?, ?> processorSupplier,
                      Set<String> sourceNodes,
                      final String queryableStoreName,
                      boolean isQueryable);  KTableImpl(KStreamBuilder topology,
                      String name,
                      ProcessorSupplier<?, ?> processorSupplier,
                      final Serde<K> keySerde,
                      final Serde<V> valSerde,
                      Set<String> sourceNodes,
                      final String queryableStoreName,
                      boolean isQueryable); @Override String queryableStoreName(); @Override KTable<K, V> filter(final Predicate<? super K, ? super V> predicate); @Override KTable<K, V> filter(final Predicate<? super K, ? super V> predicate, final String queryableStoreName); @Override KTable<K, V> filter(final Predicate<? super K, ? super V> predicate, final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V> filterNot(final Predicate<? super K, ? super V> predicate); @Override KTable<K, V> filterNot(final Predicate<? super K, ? super V> predicate, final String queryableStoreName); @Override KTable<K, V> filterNot(final Predicate<? super K, ? super V> predicate, final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V1> mapValues(final ValueMapper<? super V, ? extends V1> mapper); @Override KTable<K, V1> mapValues(final ValueMapper<? super V, ? extends V1> mapper,
                                        final Serde<V1> valueSerde,
                                        final String queryableStoreName); @Override KTable<K, V1> mapValues(final ValueMapper<? super V, ? extends V1> mapper,
                                         final Serde<V1> valueSerde,
                                         final StateStoreSupplier<KeyValueStore> storeSupplier); @Override void print(); @Override void print(String streamName); @Override void print(Serde<K> keySerde, Serde<V> valSerde); @Override void print(Serde<K> keySerde, Serde<V> valSerde, String streamName); @Override void writeAsText(String filePath); @Override void writeAsText(String filePath, String streamName); @Override void writeAsText(String filePath, Serde<K> keySerde, Serde<V> valSerde); @Override void writeAsText(String filePath, String streamName, Serde<K> keySerde, Serde<V> valSerde); @Override void foreach(final ForeachAction<? super K, ? super V> action); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic,
                                final String queryableStoreName); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic,
                                final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final String topic,
                                final String queryableStoreName); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final String topic,
                                final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V> through(final Serde<K> keySerde,
                                final Serde<V> valSerde,
                                final String topic); @Override KTable<K, V> through(final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic,
                                final String queryableStoreName); @Override KTable<K, V> through(final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic,
                                final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V> through(final StreamPartitioner<? super K, ? super V> partitioner,
                                final String topic); @Override KTable<K, V> through(final String topic,
                                final String queryableStoreName); @Override KTable<K, V> through(final String topic,
                                final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, V> through(final String topic); @Override void to(String topic); @Override void to(StreamPartitioner<? super K, ? super V> partitioner, String topic); @Override void to(Serde<K> keySerde, Serde<V> valSerde, String topic); @Override void to(Serde<K> keySerde, Serde<V> valSerde, StreamPartitioner<? super K, ? super V> partitioner, String topic); @Override KStream<K, V> toStream(); @Override KStream<K1, V> toStream(KeyValueMapper<? super K, ? super V, ? extends K1> mapper); @Override KTable<K, R> join(final KTable<K, V1> other,
                                     final ValueJoiner<? super V, ? super V1, ? extends R> joiner); @Override KTable<K, R> join(final KTable<K, V1> other,
                                     final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                     final Serde<R> joinSerde,
                                     final String queryableStoreName); @Override KTable<K, R> join(final KTable<K, V1> other,
                                     final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                     final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, R> outerJoin(final KTable<K, V1> other,
                                          final ValueJoiner<? super V, ? super V1, ? extends R> joiner); @Override KTable<K, R> outerJoin(final KTable<K, V1> other,
                                          final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                          final Serde<R> joinSerde,
                                          final String queryableStoreName); @Override KTable<K, R> outerJoin(final KTable<K, V1> other,
                                          final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                          final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KTable<K, R> leftJoin(final KTable<K, V1> other,
                                         final ValueJoiner<? super V, ? super V1, ? extends R> joiner); @Override KTable<K, R> leftJoin(final KTable<K, V1> other,
                                         final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                         final Serde<R> joinSerde,
                                         final String queryableStoreName); @Override KTable<K, R> leftJoin(final KTable<K, V1> other,
                                         final ValueJoiner<? super V, ? super V1, ? extends R> joiner,
                                         final StateStoreSupplier<KeyValueStore> storeSupplier); @Override KGroupedTable<K1, V1> groupBy(KeyValueMapper<? super K, ? super V, KeyValue<K1, V1>> selector,
                                                  Serde<K1> keySerde,
                                                  Serde<V1> valueSerde); @Override KGroupedTable<K1, V1> groupBy(KeyValueMapper<? super K, ? super V, KeyValue<K1, V1>> selector); static final String JOINTHIS_NAME; static final String JOINOTHER_NAME; static final String MERGE_NAME; static final String SOURCE_NAME; static final String STATE_STORE_NAME; }