@Override
  public SchemaKStream<?> buildStream(final PlanBuildContext builderContext) {
    final Stacker contextStacker = builderContext.buildNodeContext(getId().toString());

    return getSource().buildStream(builderContext)
        .filter(
            getPredicate(),
            contextStacker
        );
  }
@SuppressFBWarnings("RV_RETURN_VALUE_IGNORED_INFERRED")
  @Test
  public void shouldUseRightOpName() {
    // When:
    node.buildStream(planBuildContext);

    // Then:
    verifyNoMoreInteractions(stacker);
  }