public static <K> KStreamHolder<K> build(
      final KStreamHolder<K> stream,
      final StreamFilter<K> step,
      final RuntimeBuildContext buildContext) {
    return build(stream, step, buildContext, SqlPredicate::new);
  }
@Test
  public void shouldUseCorrectNameForProcessingLogger() {
    // When:
    step.build(planBuilder, planInfo);

    // Then:
    verify(buildContext).getProcessingLogger(queryContext);
  }