ASF GitHub Bot commented on FLINK-9165:

Github user Bekreth commented on the issue:

    What I was hoping to achieve was a CassandraSink that could write objects 
as single statements, or in a batch statement.  This would allow for minor 
transaction protection, guarenteeing a group of elements are all successfully 
written together.  However, it seems clear to me that I missed the forest for 
the trees on this one.  Looking over the `SinkFunction`, its clear to me the 
only way this functionality could be added would be to overload the `invoke` 
method on the `@Public` interface.  

> Improve CassandraSinkBase to send Collections
> ---------------------------------------------
>                 Key: FLINK-9165
>                 URL: https://issues.apache.org/jira/browse/FLINK-9165
>             Project: Flink
>          Issue Type: Improvement
>          Components: Cassandra Connector
>    Affects Versions: 1.4.2
>            Reporter: Christopher Hughes
>            Priority: Minor
>              Labels: easyfix, feature
> The CassandraSinkBase can currently only handle individual objects.  I 
> propose overloading the `send(IN value)` method to include 
> `send(Collection<IN> value)`. 

This message was sent by Atlassian JIRA

Reply via email to