public SeaTunnelRow reconvert(InternalRow record) throws IOException {
        if (isMultiTable) {
            String tableId = record.getString(1);
            return rowSerializationMap.get(tableId).reconvert(record);
        }
        return rowSerialization.reconvert(record);
    }
@Test
    public void testWriteConverter() throws IOException {
        initSchema();
        initData();
        MultiTableManager multiTableManager =
                new MultiTableManager(new CatalogTable[] {catalogTable1});
        SeaTunnelRow seaTunnelRow = multiTableManager.reconvert(specificInternalRow1);
        for (int i = 0; i < seaTunnelRow.getFields().length; i++) {
            Object[] values = seaTunnelRow.getFields();
            Object[] actual = seaTunnelRow1.getFields();
            for (int v = 0; v < values.length; v++) {
                if (values[v] instanceof Object[]) {
                    Assertions.assertArrayEquals((Object[]) values[v], (Object[]) actual[v]);
                } else {
                    Assertions.assertEquals(values[v], actual[v]);
                }
            }
        }
    }