[fluss-client] Support Complex Data Types on the Java Typed API (Map and Array)#2814
Merged
Conversation
polyzos
reviewed
Mar 9, 2026
Contributor
|
@nhuantho thank you for your contribution. It's almost there, and I left a few comments. |
Contributor
Author
|
Hi @polyzos, could you review it again for me?
|
Contributor
|
@nhuantho Thank you for this.. i pushed some small improvements and added test to the existing |
hemanthsavasere
pushed a commit
to hemanthsavasere/fluss
that referenced
this pull request
Mar 14, 2026
…and Array) (apache#2814) * [fluss-client] Add pojo array to fluss array * [fluss-client] Add pojo map to fluss map * [fluss-client] Create shared utilities for POJO type and Fluss type * [fluss-client] Create shared utilities for Fluss type to Pojo type * [fluss-client] Add Fluss array to Pojo array * [fluss-client] Add Fluss map to Pojo map * [ci] Fix Compile Java 8 * Revert _partial_config.mdx * [fluss-client] Hanle primitive arrays * [fluss-client] Refactor PojoMapToFlussMap to follow the same conversion logic as PojoArrayToFlussArray * [fluss-client] Change validateCompatibility logic for MAP and ARRAY types * small fixes and add tests to FlussTypedClient * fix checkstyle * fix checkstyle --------- Co-authored-by: ipolyzos <ipolyzos.se@gmail.com>
wxplovecc
pushed a commit
to tongcheng-elong/fluss
that referenced
this pull request
Apr 17, 2026
…and Array) (apache#2814) * [fluss-client] Add pojo array to fluss array * [fluss-client] Add pojo map to fluss map * [fluss-client] Create shared utilities for POJO type and Fluss type * [fluss-client] Create shared utilities for Fluss type to Pojo type * [fluss-client] Add Fluss array to Pojo array * [fluss-client] Add Fluss map to Pojo map * [ci] Fix Compile Java 8 * Revert _partial_config.mdx * [fluss-client] Hanle primitive arrays * [fluss-client] Refactor PojoMapToFlussMap to follow the same conversion logic as PojoArrayToFlussArray * [fluss-client] Change validateCompatibility logic for MAP and ARRAY types * small fixes and add tests to FlussTypedClient * fix checkstyle * fix checkstyle --------- Co-authored-by: ipolyzos <ipolyzos.se@gmail.com>
wxplovecc
pushed a commit
to tongcheng-elong/fluss
that referenced
this pull request
Apr 20, 2026
…and Array) (apache#2814) * [fluss-client] Add pojo array to fluss array * [fluss-client] Add pojo map to fluss map * [fluss-client] Create shared utilities for POJO type and Fluss type * [fluss-client] Create shared utilities for Fluss type to Pojo type * [fluss-client] Add Fluss array to Pojo array * [fluss-client] Add Fluss map to Pojo map * [ci] Fix Compile Java 8 * Revert _partial_config.mdx * [fluss-client] Hanle primitive arrays * [fluss-client] Refactor PojoMapToFlussMap to follow the same conversion logic as PojoArrayToFlussArray * [fluss-client] Change validateCompatibility logic for MAP and ARRAY types * small fixes and add tests to FlussTypedClient * fix checkstyle * fix checkstyle --------- Co-authored-by: ipolyzos <ipolyzos.se@gmail.com>
Ugbot
pushed a commit
to Ugbot/fluss
that referenced
this pull request
Apr 26, 2026
…and Array) (apache#2814) * [fluss-client] Add pojo array to fluss array * [fluss-client] Add pojo map to fluss map * [fluss-client] Create shared utilities for POJO type and Fluss type * [fluss-client] Create shared utilities for Fluss type to Pojo type * [fluss-client] Add Fluss array to Pojo array * [fluss-client] Add Fluss map to Pojo map * [ci] Fix Compile Java 8 * Revert _partial_config.mdx * [fluss-client] Hanle primitive arrays * [fluss-client] Refactor PojoMapToFlussMap to follow the same conversion logic as PojoArrayToFlussArray * [fluss-client] Change validateCompatibility logic for MAP and ARRAY types * small fixes and add tests to FlussTypedClient * fix checkstyle * fix checkstyle --------- Co-authored-by: ipolyzos <ipolyzos.se@gmail.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
2 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Purpose
Linked issue: close #2805
ARRAYandMAPtypes when converting betweenFluss internal typesandPOJO types.Brief change log
New Utilities
FlussTypeToPojoTypeConverter: shared utilities for converting Fluss types to POJO types.charLengthExceptionMessagetoConverterCommons, since it is used by both:toBinaryStringForTextinConverterCommons.convertTextValueinFlussTypeToPojoTypeConverter.validateCompatibilitylogic supported for MAP and ARRAY typesNew Adapter Classes:
FlussArrayToPojoArray: converts Fluss InternalArray → POJO array.FlussMapToPojoMap: converts Fluss InternalMap → POJO Map.PojoArrayToFlussArray: converts POJO array → Fluss InternalArray.PojoMapToFlussMap: converts POJO Map → Fluss InternalMap.Converter Updates
ARRAYandMAPin:PojoToRowConverter.RowToPojoConverter.Tests
Updated
ConvertersTestFixturesto include logic forMAPandARRAYtypes.FlussArrayToPojoArrayTestto verify all array conversion cases.PojoArrayToFlussArrayTestto verify all array conversion cases.Added testMapType in:
PojoToRowConverterTest.RowToPojoConverterTest.Removed
testUnsupportedSchemaFieldTypeThrowsfromPojoToRowConverterTest.API and Format
Documentation