".
>>>
>>> Also, the dbSession isn't really Flink state as it will not vary based
>>> on the position in or content in the stream. It's a necessary helper
>>> object, yes, but you don't need Flink to checkpoint it.
>>>
>>>
heckpoint it.
>>
>> You can still use the sinks provided with flink-connector-cassandra and
>> customize the cluster building by passing your own ClusterBuilder into the
>> constructor.
>>
>> -Shannon
>>
>> From: Meghashyam Sandeep V
>> Date: Fr
e
> constructor.
>
> -Shannon
>
> From: Meghashyam Sandeep V
> Date: Friday, December 9, 2016 at 12:26 PM
> To: ,
> Subject: Reg. custom sinks in Flink
>
> Hi there,
>
> I have a flink streaming app where my source is Kafka and a custom sink to
&
Hi there,
I have a flink streaming app where my source is Kafka and a custom sink to
Cassandra(I can't use standard C* sink that comes with flink as I have
customized auth to C*). I'm currently have the following:
messageStream
.rebalance()
.map( s-> {
return mapper.readValu
assandra and
customize the cluster building by passing your own ClusterBuilder into the
constructor.
-Shannon
From: Meghashyam Sandeep V
mailto:vr1meghash...@gmail.com>>
Date: Friday, December 9, 2016 at 12:26 PM
To: mailto:u...@flink.apache.org>>,
mailto:dev@flink.apache.org>>
Sub
