Как построить потоковое выражение с StreamFactory - PullRequest
0 голосов
/ 19 июня 2019

Я пытаюсь построить выражение let для потока solr, но выдает сообщение об ошибке Причина: java.io.IOException: Недопустимое выражение потока col (samples, score) - функция 'col' неизвестна (не сопоставлена ​​с действительным TupleStream)

StreamFactory = new StreamFactory().withDefaultZkHost(zookeeper)
        .withFunctionName("search", CloudSolrStream.class) 
        .withFunctionName("select", SelectStream.class)
        .withFunctionName("merge", MergeStream.class) 
        .withFunctionName("sort", SortStream.class) 
        .withFunctionName("tuple", TupStream.class) 
        .withFunctionName("rollup", RollupStream.class) 
        .withFunctionName("hashJoin", HashJoinStream.class)
        .withFunctionName("count", CountMetric.class) 
        .withFunctionName("facet", FacetStream.class) 
        .withFunctionName("sum", SumMetric.class) 
        .withFunctionName("unique", UniqueStream.class) 
        .withFunctionName("significantTerms", SignificantTermsStream.class)
        .withFunctionName("stats", StatsStream.class)
        .withFunctionName("innerJoin", InnerJoinStream.class) 
        .withFunctionName("issnMerge", IssnMergeStream.class) 
        .withFunctionName("intersect", IntersectStream.class)
        .withFunctionName("boostByEra", BoostBooksByEraExpression.class)
        .withFunctionName("determineRRec", DetermineRepresentativeRecord.class)
        .withFunctionName("plist", ParallelListStream.class)
        .withFunctionName("let", LetStream.class);

Мое выражение выглядит следующим образом:

let (samples = search (wc_art, qt = "/ select", q = "al: next AND al: generation", fq= "_ delete: false", fq = "_ namespace: default", fl = "Score, numdocs (), id", row = 10, fq = "{! lucene q.op = OR} pa: (medline)",defType = edismax, q.op = AND, sort = "Score desc"), отклики = col (образцы, оценка), итоговые = описание (ответы))

1 Ответ

0 голосов
/ 20 июня 2019

Функция col была добавлена ​​в Solr 7, поэтому, если ваша версия Solr устарела, эта функция будет недоступна.Обновление до более новой версии.

...