gistfile1.scala

def thoughtstream(count: Int)(implicit env: Environment):Seq[thought] = {
  qLogger.debug("Executing query 'thoughtstream'")
  topK(IntegerField(count),
   sort(List("timestamp"), true,
    materialize(classOf[thought],
     sequentialDereferenceIndex("ent_thought", ReadRandomPolicy,
      prefixJoin("idxthoughtowner_timestamp", List(AttributeCondition("name")), IntegerField(count), true, ReadRandomPolicy,
       materialize(classOf[user],
        pointerJoin("ent_user", List(AttributeCondition("target")), ReadRandomPolicy,
         selection(HashMap(("approved", TrueField)).asInstanceOf[HashMap[String, Field]],
          materialize(classOf[subscription],
           prefixJoin("ent_subscription", List(AttributeCondition("name")), IntegerField(5000), true, ReadRandomPolicy,
            materialize(classOf[user],
             singleGet("ent_user", name, ReadRandomPolicy)
            )
           )
          )
         )
        )
       )
      )
     )
    )
   )
  )
 }