title: CassandraBeamIO conversion Into Pcollection of ROWS
body: <p>I am trying to read Data from Cassandra db using apache beam CassandraIO , my requirement is crating a Pcollection of Rows from cassandra db , currently my code look like this</p>
  <pre class="lang-java prettyprint-override"><code>PTransform&lt;PBegin,PCollection&lt;Row&gt;&gt;transform=CassandraIO.&lt;Row&gt;read()
     .withHosts(Collections.singletonList(&quot;127.0.0.1&quot;))
     .withPort(9042)
     .withKeyspace(&quot;\&quot;testDb\&quot;&quot;)
     .withMapperFactoryFn(new CassandraRowMapper())
     .withQuery(q)
     .withTable(&quot;student&quot;)
     .withEntity(Row.class)
     .withCoder(SerializableCoder.of(Row.class));
  </code></pre>
  <p>any help will be appreciated</p>