bigtable_query.scala

    implicit def toFilter1(property:Symbol) = new { 
      def ===(value:Any):Query => Query = 
        query => query.addFilter(property.toString, Query.FilterOperator.EQUAL, value) 
    }
    class DataStore(){ 
    	val ds = DatastoreServiceFactory.getDatastoreService()
    	def from(name:Symbol) = new Filter(ds, new Query(name.toString)) 
    }
    class Filter(ds:DatastoreService, query:Query){ def where(predicate:Query => Query) = new FetchOption(ds, predicate(query))}
    class FetchOption(ds:DatastoreService, query:Query){ 
    	def limit(offset:Int, limit:Int) = new {
    	  def asIterator() = ds.prepare(query).asIterable(FetchOptions.Builder.withLimit(limit).offset(offset)) 
    	} 
     }
    
// Sample Query
    new DataStore() from('Person) where('age === 9) limit(1, 3) asIterator