joel-bernstein

complement(on="Product_s, Actual_Start_Date_dt",
           sort(by="Product_s asc, Actual_Start_Date_dt asc",
                having(select(innerJoin(search(cp, q="*:*", fl="id, Product_s, Reported_Date_dt", sort="Product_s asc", qt="/export"),
                                        search(cp-changes, q="*:*", fq="Actual_Start_Date_dt.epoch:[1 TO *]", fl="id, Product_Name_s, Actual_Start_Date_dt", sort="Product_Name_s asc", qt="/export"),
                                        on="Product_s=Product_Name_s"),
                              id, Product_s, Product_Name_s, Reported_Date_dt, Actual_Start_Date_dt, sub(epoch(Reported_Date_dt), epoch(Actual_Start_Date_dt)) as diff),
                       and(gt(diff, 0), lt(diff, 86400000)))),
           sort(by="Product_s asc, Actual_Start_Date_dt asc",
                having(select(innerJoin(search(cp, q="*:*", fl="id, Product_s, Reported_Date_dt", sort="Product_s asc", qt="/export"),
                                        search(cp-changes, q="*:*", fq="Actual

joel-bernstein

select(timeseries(collection1, q=“*:*”, 
                  field="Reported_Date_dt", 
                  start="2018-07-20T00:00:00Z", 
                  end="2018-08-20T23:59:59Z", 
                  gap="+1DAY", 
                  format="YYYY-MM-dd", 
                  sum(a), 
                  sum(b)),
       Reported_Date_dt,
       sum(a) as sumA,

joel-bernstein

plist(facet(collection1, q="stock_s:(1 2 3)", buckets="prod_ss, stock_s, day_i", bucketSizeLimit="-1", bucketSorts="index asc", count(*), sum(price_i), sum(price_f), sum(service_d), sum(componentA_d)),
      facet(collection1, q="stock_s:(4 5 6)", buckets="prod_ss, stock_s, day_i", bucketSizeLimit="-1", bucketSorts="index asc", count(*), sum(price_i), sum(price_f), sum(service_d), sum(componentA_d)),
      facet(collection1, q="stock_s:(7 8 9)", buckets="prod_ss, stock_s, day_i", bucketSizeLimit="-1", bucketSorts="index asc", count(*), sum(price_i), sum(price_f), sum(service_d), sum(componentA_d)))

joel-bernstein

plist(parallel(workerCollection,
               numWorkers="1",
               sort="year asc, month asc, day asc",
               plist(facet(week1, zkHost="zk1", q="*:*", buckets="year, month, day", bucketSorts="year asc, month asc, day asc", count(*)), 
                     facet(week2, zkHost="zk1", q="*:*", buckets="year, month, day", bucketSorts="year asc, month asc, day asc", count(*)),
                     facet(week3, zkHost="zk1", q="*:*", buckets="year, month, day", bucketSorts="year asc, month asc, day asc", count(*)))),
     parallel(workerCollection,
              numWorkers="1",
              sort="year asc, month asc, day asc",
              plist(facet(week4, zkHost="zk2", q="*:*", buckets="year, month, day", bucketSorts="year asc, month asc, day asc", count(*)),

joel-bernstein

Add the admin password:
 curl -X POST -H "Content-type:application/json" -d '{"password":"password123"}' "http://localhost:6764/api"

Add role with authorities:
curl -u admin:password123 -X POST -H 'Content-type: application/json' -d 
'{"name":"test", "permissions":[{"methods":["GET"],"path":"/catalog/fusion/assets/**"}, 
 {"methods":["POST"],"path":"/api/apollo/catalog/fusion/query"}]}' http://localhost:6764/api/roles 
 
Add user with role:

joel-bernstein

 /*
  * Collapses groups that have been block indexed.
  */
  private static class BlockOrdScoreCollector extends DelegatingCollector {
    private int currentGroup = -1;
    private float topScore = Float.MIN_VALUE;
    private int topDoc = -1;
    private ScoreAndDoc dummy = new ScoreAndDoc();
    private String collapseField;
    private SortedDocValues segmentValues;

joel-bernstein

import org.apache.solr.client.solrj.impl.CloudSolrClient;
import org.apache.solr.client.solrj.impl.HttpSolrClient;
import org.apache.solr.client.solrj.SolrClient;
import org.apache.solr.client.solrj.request.UpdateRequest;
import org.apache.solr.common.SolrInputDocument;
import java.util.Random;
import java.util.Date;
import java.util.UUID;
import java.io.*;
import org.apache.commons.math3.distribution.NormalDistribution;

joel-bernstein

import java.util.*;
import java.io.*;
import org.apache.solr.client.solrj.impl.*;
import org.apache.solr.client.solrj.*;
import org.apache.solr.common.util.*;
import org.apache.solr.client.solrj.response.*;
import org.apache.solr.common.params.*;


public class CollapseQuery {

joel-bernstein

{
  "responseHeader":{
    "zkConnected":true,
    "status":0,
    "QTime":185,
    "params":{
      "facet.limit":"-1",
      "q":"*:*",
      "facet.field":["f1_s",
        "f2_s",

joel-bernstein

  {
  "responseHeader":{
    "zkConnected":true,
    "status":0,
    "QTime":4,
    "params":{
      "q":"*:*",
      "expand":"true",
      "indent":"true",
      "fl":"stock_s,id",