Я пытаюсь построить выражение 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 (образцы, оценка), итоговые = описание (ответы))