Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3149
Hi @fhueske ,
Regarding to the field type serialization, I think maybe we can provide
default deserialization for basic types (int,long,String...) if users do use
the `Bytes.toBytes(...)` to serialize the basic types. If not, users can ask
this field to return raw bytes in this way: `htableSchame.add("column_family",
"qualifier", byte[].class)` and then use an user defined scalar function to
deserialize the value.
regarding to the rowkeys, I agree with you. It would be great if we can set
scan range by WHERE clause. But FLINK-3849 (FilterableTableSource) is still a
pending PR, I would suggest to break this issue into two. 1. add
HBaseTableSource, provide access to HBase tables and support nested schema. 2.
extend HBaseTableSource to support FilterableTableSource.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
