Examples of io.crate.operation.reference.doc.lucene.LuceneCollectorExpression

Package io.crate.operation.reference.doc.lucene

Examples of io.crate.operation.reference.doc.lucene.LuceneCollectorExpression

io.crate.operation.reference.doc.lucene.LuceneCollectorExpression
An expression which gets evaluated in the collect phase

                                    DataType valueType,
                                    Object missingValue) {
            this.collectorExpressions = collectorExpressions;
            this.missingValue = missingValue;
            for (int i = 0, collectorExpressionsSize = collectorExpressions.size(); i < collectorExpressionsSize; i++) {
                LuceneCollectorExpression collectorExpression = collectorExpressions.get(i);
                collectorExpression.startCollect(context);
            }
            this.valueType = valueType;
            this.values = new Object[numHits];
            this.input = input;
        }

View Full Code Here


        @SuppressWarnings("unchecked")
        @Override
        public int compareBottom(int doc) throws IOException {
            for (int i = 0, collectorExpressionsSize = collectorExpressions.size(); i < collectorExpressionsSize; i++) {
                LuceneCollectorExpression collectorExpression = collectorExpressions.get(i);
                collectorExpression.setNextDocId(doc);
            }
            return valueType.compareValueTo(bottom, input.value());
        }

View Full Code Here


        @SuppressWarnings("unchecked")
        @Override
        public int compareTop(int doc) throws IOException {
            for (int i = 0, collectorExpressionsSize = collectorExpressions.size(); i < collectorExpressionsSize; i++) {
                LuceneCollectorExpression collectorExpression = collectorExpressions.get(i);
                collectorExpression.setNextDocId(doc);
            }
            return valueType.compareValueTo(top, input.value());
        }

View Full Code Here

        }


        @Override
        public void copy(int slot, int doc) throws IOException {
            for (int i = 0, collectorExpressionsSize = collectorExpressions.size(); i < collectorExpressionsSize; i++) {
                LuceneCollectorExpression collectorExpression = collectorExpressions.get(i);
                collectorExpression.setNextDocId(doc);
            }
            Object value = input.value();
            if (value == null) {
                values[slot] = missingValue;
            } else {

View Full Code Here

        }


        @Override
        public FieldComparator setNextReader(AtomicReaderContext context) throws IOException {
            for (int i = 0, collectorExpressionsSize = collectorExpressions.size(); i < collectorExpressionsSize; i++) {
                LuceneCollectorExpression collectorExpression = collectorExpressions.get(i);
                collectorExpression.setNextReader(context);
            }
            return this;
        }

View Full Code Here

TOP

Related Classes of io.crate.operation.reference.doc.lucene.LuceneCollectorExpression

io.crate.action.sql.query.CrateSearchService$InputFieldComparator

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.