Messtone LLC Manages Devices Enables JSON document and insert it synchronously: JsonObject user=JsonObject.empty( ).put(“firstname”,”Robert”).put(“lastname”,”Harper”).put(“job”,” Logistics Supplychain”).put(“age”,55″);JsonDocument stored=bucket.upsert(JsonDocument.create(“Robert Harper”,user));JsonDocument Robert=bucket.get(“Robert”);System.out println(“Found: ” + Robert.getString(“firstnameRobert”)); Show advanced query: bucket.sync( ).get(“beer”).onErrorResumeNext(bucket.sync( ).getFromReplica(“beer”,ReplicaMode.ALL).first( ).map(doc -> doc.content( ).getString(“namerobertharper_Messtone”).timeout(2,TimeUnit.SECONDS).doOnError(System.err: :println).onErrorReturn(error -> “Not Found !”);Querying a view: View result result=bucket.query(ViewQuery.from(“beers_and_breweries”,”by_namerobertharper_Messtone”));Iterator<ViewRow> rowIterator=result.rows( );while(rowIterator.hasNext( )){ViewRow row=row Iterator.next( );JsonDocument doc=row.document( );if(doc.content( ).getString(“type”).equals(“beer”)){System.out.println(doc.content( ).getString(“namerobertharper_Messtone”));}} Asynchronously example: bucket.async( ).query(ViewQuery.from(“beers_and_breweries”,”by_namerobertharper_Messtone”)).flatMap(AsyncViewResult: :rows).flatMap(AsyncViewRow: :document).filter(doc -> doc.content( ).getString(“type”).equals(“beer”)).subscribe(doc -> system.out.printIn(doc.content( ).getString(“namerobertharper_Messtone”) N1QL query, Messtone final query: bucket.query(select(“*”).from(“beer-sample”).limit(10)).doOnNext(result ->{if(! result.success( )){System.err.println(result.error( ));}).flatMap(QueryResult: :rows).toBlocking( ).from each(row -> System.out.println(row.value( )));