Hi Anton, I'm not sure why you would prefer writing your own sink connector over using a provided one. If you really want to use the DataStream API, you can also switch from the Table API to the DataStream API and back.
Best regards, Martijn (I noticed I forgot to include the user mailing list, so I've added it again in this reply) On Mon, 18 Oct 2021 at 18:59, Anton <anton...@yandex.ru> wrote: > Martijn, > > > > Is creating own sink connector by extending RichSinkFunction also welcomed? > > > > *From:* Martijn Visser [mailto:mart...@ververica.com] > *Sent:* Monday, October 18, 2021 7:43 PM > *To:* Anton <anton...@yandex.ru> > *Subject:* Re: HBase sink connector - HBaseSinkFunction vs Table API > > > > Hi, > > > > The Table API currently has support for a HBase source and sink [1] > > HBase is currently not supported in the DataStream API. > > > > Best regards, > > > > Martijn > > > > [1] > https://ci.apache.org/projects/flink/flink-docs-master/docs/connectors/table/overview/ > > > > On Mon, 18 Oct 2021 at 18:33, Anton <anton...@yandex.ru> wrote: > > Hello. Please suggest best method to write data to HBase (stream going > from Kafka being enriched with HBase data and need to be written to HBase). > There is only one connector on flink.apache.org related to Table API. At > the same time there is HBaseSinkFunction in the source code and I beleive > it relates to DataStream API. But there is an issue > https://issues.apache.org/jira/browse/FLINK-22623 which states that > HBaseTableSource/Sink and related classes have been removed. Is > HBaseSinkFunction really deleted/deprecated? What are pros and cons of > Table API’s connector and HBaseSinkFunction if it’s still supported? > >
