UDTExampleFeed.scala

class UDTExampleFeed(cass: Cassandra, keyspace: String) extends AbstractContactFeed {
  private def getTelecommunicationUDT = {
    val telecommunication_type = cass.getCluster.getMetadata.getKeyspace(keyspace).getUserType("telecommunication")
    val telecommunication = telecommunication_type.newValue()

    val row = getTelecommunicationRow
    row.foreach(p => telecommunication.setString(p._1, p._2))

    telecommunication
  }

  def getTelecommunicationsUDT = {
    def telecommunicationsData = {
      Map("telecommunications" -> (1 to 3).map(_ => {
        getTelecommunicationUDT
      }).filter(_ != false).foldLeft(Set[UDTValue]())((s, a) => s + a.asInstanceOf[UDTValue]))
    }

    Iterator.continually(telecommunicationsData)
  }
}