@Override
  public KsqlArray getKsqlArray(final int columnIndex) {
    return values.getKsqlArray(columnIndex - 1);
  }
@Test
  public void shouldGetKsqlArray() {
    assertThat(row.getKsqlArray("f_array"), is(new KsqlArray(ImmutableList.of("e1", "e2"))));
  }