@Override
  public KsqlObject getKsqlObject(final int columnIndex) {
    return values.getKsqlObject(columnIndex - 1);
  }
@Test
  public void shouldGetKsqlObject() {
    assertThat(row.getKsqlObject("f_map"), is(new KsqlObject(ImmutableMap.of("k1", "v1", "k2", "v2"))));
    assertThat(row.getKsqlObject("f_struct"), is(new KsqlObject(ImmutableMap.of("f1", "baz", "f2", 12))));
  }