fork download

copy

import java.util.Date;
import java.util.concurrent.TimeUnit;
 
import com.couchbase.client.core.time.Delay;
import com.couchbase.client.java.Bucket;
import com.couchbase.client.java.Cluster;
import com.couchbase.client.java.CouchbaseCluster;
import com.couchbase.client.java.document.JsonDocument;
import com.couchbase.client.java.document.json.JsonArray;
import com.couchbase.client.java.document.json.JsonObject;
import com.couchbase.client.java.env.CouchbaseEnvironment;
import com.couchbase.client.java.env.DefaultCouchbaseEnvironment;
import com.couchbase.client.java.error.CASMismatchException;
import com.couchbase.client.java.util.retry.RetryBuilder;
 
import rx.Observable;
import rx.functions.Action1;
import rx.functions.Func1;
 
public class DocumentExample {
 
	public static void main(String[] args) {
		try 
		{
			Cluster cluster = CouchbaseCluster.create("127.0.0.1");
 
			final Bucket bucket = cluster.openBucket("default");
 
			bucket
			    .get("Jack")
			    //compiled error with "map"
			    //error message: The method map(new Func1<JsonDocument,JsonDocument>(){}) is undefined for the type JsonDocument
			    .map(new Func1<JsonDocument, JsonDocument>() {
			        @Override
			        public JsonDocument call(JsonDocument jack) {
			        	jack.content().put("gender","male");
			            return jack;
			        }
			    })
			    .flatMap(new Func1<JsonDocument, Observable<JsonDocument>>() {
			        @Override
			        public Observable<JsonDocument> call(JsonDocument jack) {
			        	//compiled error with in this code
			        	//error message:Type mismatch: cannot convert from JsonDocument to Observable<JsonDocument>
			            return bucket.replace(jack);
			        }
			    })
			    .subscribe(new Action1<JsonDocument>() {
					@Override
				    public void call(final JsonDocument updated) {
						System.out.println("updated: " + updated.id());
					}
				});
 
 
 
			cluster.disconnect();
		} catch (Exception e) {
			e.printStackTrace();
		}
 
	}
 
}
 

Main.java:20: error: class DocumentExample is public, should be declared in a file named DocumentExample.java
public class DocumentExample {
       ^
Main.java:4: error: package com.couchbase.client.core.time does not exist
import com.couchbase.client.core.time.Delay;
                                     ^
Main.java:5: error: package com.couchbase.client.java does not exist
import com.couchbase.client.java.Bucket;
                                ^
Main.java:6: error: package com.couchbase.client.java does not exist
import com.couchbase.client.java.Cluster;
                                ^
Main.java:7: error: package com.couchbase.client.java does not exist
import com.couchbase.client.java.CouchbaseCluster;
                                ^
Main.java:8: error: package com.couchbase.client.java.document does not exist
import com.couchbase.client.java.document.JsonDocument;
                                         ^
Main.java:9: error: package com.couchbase.client.java.document.json does not exist
import com.couchbase.client.java.document.json.JsonArray;
                                              ^
Main.java:10: error: package com.couchbase.client.java.document.json does not exist
import com.couchbase.client.java.document.json.JsonObject;
                                              ^
Main.java:11: error: package com.couchbase.client.java.env does not exist
import com.couchbase.client.java.env.CouchbaseEnvironment;
                                    ^
Main.java:12: error: package com.couchbase.client.java.env does not exist
import com.couchbase.client.java.env.DefaultCouchbaseEnvironment;
                                    ^
Main.java:13: error: package com.couchbase.client.java.error does not exist
import com.couchbase.client.java.error.CASMismatchException;
                                      ^
Main.java:14: error: package com.couchbase.client.java.util.retry does not exist
import com.couchbase.client.java.util.retry.RetryBuilder;
                                           ^
Main.java:16: error: package rx does not exist
import rx.Observable;
         ^
Main.java:17: error: package rx.functions does not exist
import rx.functions.Action1;
                   ^
Main.java:18: error: package rx.functions does not exist
import rx.functions.Func1;
                   ^
Main.java:25: error: cannot find symbol
			Cluster cluster = CouchbaseCluster.create("127.0.0.1");
			^
  symbol:   class Cluster
  location: class DocumentExample
Main.java:25: error: cannot find symbol
			Cluster cluster = CouchbaseCluster.create("127.0.0.1");
			                  ^
  symbol:   variable CouchbaseCluster
  location: class DocumentExample
Main.java:27: error: cannot find symbol
			final Bucket bucket = cluster.openBucket("default");
			      ^
  symbol:   class Bucket
  location: class DocumentExample
Main.java:48: error: cannot find symbol
			    .subscribe(new Action1<JsonDocument>() {
			                   ^
  symbol:   class Action1
  location: class DocumentExample
Main.java:48: error: cannot find symbol
			    .subscribe(new Action1<JsonDocument>() {
			                           ^
  symbol:   class JsonDocument
  location: class DocumentExample
Main.java:40: error: cannot find symbol
			    .flatMap(new Func1<JsonDocument, Observable<JsonDocument>>() {
			                 ^
  symbol:   class Func1
  location: class DocumentExample
Main.java:40: error: cannot find symbol
			    .flatMap(new Func1<JsonDocument, Observable<JsonDocument>>() {
			                       ^
  symbol:   class JsonDocument
  location: class DocumentExample
Main.java:40: error: cannot find symbol
			    .flatMap(new Func1<JsonDocument, Observable<JsonDocument>>() {
			                                     ^
  symbol:   class Observable
  location: class DocumentExample
Main.java:40: error: cannot find symbol
			    .flatMap(new Func1<JsonDocument, Observable<JsonDocument>>() {
			                                                ^
  symbol:   class JsonDocument
  location: class DocumentExample
Main.java:33: error: cannot find symbol
			    .map(new Func1<JsonDocument, JsonDocument>() {
			             ^
  symbol:   class Func1
  location: class DocumentExample
Main.java:33: error: cannot find symbol
			    .map(new Func1<JsonDocument, JsonDocument>() {
			                   ^
  symbol:   class JsonDocument
  location: class DocumentExample
Main.java:33: error: cannot find symbol
			    .map(new Func1<JsonDocument, JsonDocument>() {
			                                 ^
  symbol:   class JsonDocument
  location: class DocumentExample
27 errors

Standard output is empty