public <K> KsqlTransformer<K, Optional<GenericRow>> getTransformer(
      final ProcessingLogger processingLogger
  ) {
    return new Transformer<>(processingLogger);
  }
@Test
  public void shouldCompileEvaluator() {
    // Given:
    predicate = new SqlPredicate(
        new ComparisonExpression(Type.LESS_THAN, COL0, new LongLiteral(100)),
        SCHEMA,
        KSQL_CONFIG,
        functionRegistry
    );

    transformer = predicate.getTransformer(processingLogger);

    // When:
    final Optional<GenericRow> result1 = transformer.transform("key", genericRow(99L), ctx);
    final Optional<GenericRow> result2 = transformer.transform("key", genericRow(100L), ctx);

    // Then:
    assertThat(result1, is(not(Optional.empty())));
    assertThat(result2, is(Optional.empty()));
  }