SeanTAllen

val storeOp = new StoreOperation.Builder(location).withContent(ro).withW(1).withTimeout(1500).build()

riakCluster.operationComplete(storeOp, 3)

SeanTAllen

withTimeout on StoreOperation is how long to allow for the store complete.

get(t,u) is how long we would wait on it completing.

if the get timeout is less than withTimeout for StoreOperation, the operation might still complete but we wouldn't be waiting for confirmation.

is that correct?

SeanTAllen

package com.theladders.match_jobseekers_with_jobs;
 
import com.basho.riak.client.query.RiakObject;
import com.basho.riak.client.query.indexes.LongIntIndex;
 
public class IndexAdder
{
  public static void addLongIntIndex(RiakObject ro, String name, Long value) {
    ro.getIndexes()
        .getIndex(new LongIntIndex.Name(name))

SeanTAllen

the scala:

    val payload =  BinaryValue.create(pairs.asJson())
    val ro: RiakObject = new RiakObject().setContentType("application/json").setValue(payload)
    IndexAdder.addLongIntIndex(ro, "jobseeker", jobseekerId)
    
the solutions other part:

package com.theladders.match_jobseekers_with_jobs;

SeanTAllen

    val payload =  BinaryValue.create(pairs.asJson())
    val ro = new RiakObject().setContentType("application/json").setValue(payload)
    ro.getUserMeta.put(BinaryValue.createFromUtf8("x-riak-index-jobseeker_int"), BinaryValue.createFromUtf8(jobseekerId.toString))
    val storeOp = new StoreOperation.Builder(location).withContent(ro).build()
    riakCluster.execute(storeOp)
    
    I see the header set but when I try to look up the value by the index, I can't find. Thoughts?

SeanTAllen

new String(Base64.decodeBase64(new String(Base64.encodeBase64("123".getBytes, false))))

SeanTAllen

      val foo = new RiakObjectBuilder().withContentType("application/json").withValue("{'key':'value'}").build()
      
      riak.fetchBucket("foofoo").execute().store(foo).execute()

SeanTAllen

-Xmn2g 
-XX:+PrintGCTimeStamps 
-XX:+PrintGCDetails 
-Xloggc:/opt/es-debug/gc.log -XX:+PrintGCDateStamps 
-XX:+PrintGCApplicationStoppedTime 
-XX:+PrintGCApplicationConcurrentTime 
-XX:+PrintSafepointStatistics

SeanTAllen

.
├── README.md
├── pom.xml
└── src
    └── main
        ├── java
        │   └── stormapplied
        │       └── creditcard
        │           ├── LocalTopologyRunner.java
        │           ├── Order.java

SeanTAllen

├── README.md
├── pom.xml
└── src
    └── main
        ├── java
        │   └── stormapplied
        │       └── githubcommits
        │           ├── LocalTopologyRunner.java
        │           └── topology
        │               ├── CommitFeedListener.java