You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Max Charas (JIRA)" <ji...@apache.org> on 2019/03/13 10:03:00 UTC

[jira] [Created] (BEAM-6820) Custom Row-Object mapper implementation for CassandraIO

Max Charas created BEAM-6820:
--------------------------------

             Summary: Custom Row-Object mapper implementation for CassandraIO
                 Key: BEAM-6820
                 URL: https://issues.apache.org/jira/browse/BEAM-6820
             Project: Beam
          Issue Type: Improvement
          Components: io-java-cassandra
            Reporter: Max Charas


The current Cassandra source sink is tightly coupled to the Datastax Object Mapper. [This requires users|https://docs.datastax.com/en/developer/java-driver/3.1/manual/object_mapper/] of the sink to provide a POJO describing  the table in Cassandra. Although the POJO is a easy and powerful way to describe the table it does requires users to always recompile the pipeline for each change in the table definition. 

I suggest adding a abstraction layer that allows users to inject their own mapper implementation. One example use would be a mapper that works with a generic [Row|https://beam.apache.org/releases/javadoc/2.4.0/org/apache/beam/sdk/values/Row.html] implementation rather than a compile-time POJO. 

This abstraction layer could be implemented by simply supplying a MapperFactory through the Sink/Source builder. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)