@Test
public void assertGetInputStreamByColumnIndex() throws IOException {

    aggregationDistinctQueryResult.next();
    assertThat(aggregationDistinctQueryResult.getInputStream(1, "Unicode").read(), is(getInputStream(10).read()));
}