Cassandra connector POJO - tombstone question

Hi, I am using flink-1.2 and Cassandra connector to write to cassandra tables. I am using POJOs with DataStax annotations as described here- https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/cassandra.html My question is- how are nulls handles by cassandra sink? Datastax

Re: Cassandra connector POJO - tombstone question

Hello, what i can do is add hook like we do for the ClusterBuilder with which you can provide a set of options that will be used for every call to the mapper. This would provide you access with all options that are listed on the page you linked. You can find an implementation of this here: h

Re: Cassandra connector POJO - tombstone question

Thanks Chesnay, this will work. Best, Tarandeep On Wed, Apr 12, 2017 at 2:42 AM, Chesnay Schepler wrote: > Hello, > > what i can do is add hook like we do for the ClusterBuilder with which you > can provide a set of options that will > be used for every call to the mapper. This would provide yo

Re: Cassandra connector POJO - tombstone question

Hi Chesnay, Did your code changes (exposing mapper options) made it in 1.3 release? Thank you, Tarandeep On Wed, Apr 12, 2017 at 2:34 PM, Tarandeep Singh wrote: > Thanks Chesnay, this will work. > > Best, > Tarandeep > > On Wed, Apr 12, 2017 at 2:42 AM, Chesnay Schepler > wrote: > >> Hello, >

Re: Cassandra connector POJO - tombstone question

No, unfortunately I forgot about them :/ On 01.06.2017 19:39, Tarandeep Singh wrote: Hi Chesnay, Did your code changes (exposing mapper options) made it in 1.3 release? Thank you, Tarandeep On Wed, Apr 12, 2017 at 2:34 PM, Tarandeep Singh > wrote: Thanks Ches

Re: Cassandra connector POJO - tombstone question

No problem :) Thanks for letting me know. Best, Tarandeep On Thu, Jun 1, 2017 at 11:18 AM, Chesnay Schepler wrote: > No, unfortunately I forgot about them :/ > > > On 01.06.2017 19:39, Tarandeep Singh wrote: > > Hi Chesnay, > > Did your code changes (exposing mapper options) made it in 1.3 rele