@Override
  public LogicalSchema getSchema() {
    return outputSchema;
  }
@Test
  public void shouldBuildPullQueryOutputSchemaSelectKeyNonWindowed() {
    // Given:
    selects = ImmutableList.of(new SingleColumn(K_REF, Optional.of(K)));
    when(keyFormat.isWindowed()).thenReturn(false);
    when(analysis.getSelectColumnNames()).thenReturn(ImmutableSet.of(K));

    // When:
    final QueryProjectNode projectNode = new QueryProjectNode(
        NODE_ID,
        source,
        selects,
        metaStore,
        ksqlConfig,
        analysis,
        false,
        plannerOptions,
        false
    );

    // Then:
    final LogicalSchema expected = LogicalSchema.builder()
        .keyColumn(K, SqlTypes.STRING)
        .build();

    assertThat(expected, is(projectNode.getSchema()));
  }