@Override
    public byte[] getBytes(int columnIndex) throws SQLException {
        checkClosed();
        checkValidRow();
        checkValidColumn(columnIndex);
        try {
            return currentRow.getBinary(columnIndex - 1);
        } catch (Exception e) {
            throw new SQLDataException(e);
        }
    }
@Test
    public void testResultSetPrimitiveData() throws Exception {
        CloseableIterator<RowData> data =
                CloseableIterator.adapterForIterator(
                        IntStream.range(0, RECORD_SIZE)
                                .boxed()
                                .map(
                                        v -> {
                                            Map<StringData, MapData> map = new HashMap<>();
                                            Map<Integer, Long> valueMap = new HashMap<>();
                                            valueMap.put(v, v.longValue());
                                            map.put(
                                                    StringData.fromString(v.toString()),
                                                    new GenericMapData(valueMap));
                                            return (RowData)
                                                    GenericRowData.of(
                                                            v % 2 == 0,
                                                            v.byteValue(),
                                                            v.shortValue(),
                                                            v,
                                                            v.longValue(),
                                                            (float) (v + 0.1),
                                                            v + 0.22,
                                                            DecimalData.fromBigDecimal(
                                                                    new BigDecimal(v + ".55555"),
                                                                    10,
                                                                    5),
                                                            StringData.fromString(v.toString()),
                                                            v.toString().getBytes(),
                                                            new GenericMapData(map));
                                        })
                                .iterator());
        try (ResultSet resultSet =
                new FlinkResultSet(
                        new TestingStatement(),
                        new StatementResult(
                                SCHEMA, data, true, ResultKind.SUCCESS, JobID.generate()))) {
            validateResultData(resultSet);
        }
    }