public boolean getOrReplace() {
    return orReplace;
  }
@Test
  public void shouldSetReplaceFlagToTrue() {
    // When
    final KsqlStructuredDataOutputNode outputNode = new KsqlStructuredDataOutputNode(
        PLAN_NODE_ID,
        sourceNode,
        SCHEMA,
        Optional.empty(),
        ksqlTopic,
        OptionalInt.empty(),
        createInto,
        SourceName.of(PLAN_NODE_ID.toString()),
        true);

    // Then
    assertThat(outputNode.getOrReplace(), is(true));
  }