Package io.crate.operation.projectors

Examples of io.crate.operation.projectors.Projector

38
39
40
41
42
43
44
45
46
47
48
    private final List<Input<?>> inputs = ImmutableList.<Input<?>>of(
            Literal.newLiteral(true), Literal.newLiteral("foo"));

    @Test
    public void testCollectOneRow() throws Exception {
        Projector downStream = mock(Projector.class);
        SimpleOneRowCollector collector = new SimpleOneRowCollector(
                inputs,
                Collections.<CollectExpression<?>>emptySet(),
                downStream
        );
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
106
107
108
                       // there can be only 1 projection on the shard
            }
            idx++;
        }

        Projector previousProjector = null;
        // create the node level projectors
        for (int i = shardProjectionsIndex + 1; i < projections.size(); i++) {
            Projector projector = nodeProjectorVisitor.process(projections.get(i));
            nodeProjectors.add(projector);
            if (previousProjector != null) {
                previousProjector.downstream(projector);
            } else {
                firstNodeProjector = projector;
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
     */
    public Projector newShardDownstreamProjector(ProjectionToProjectorVisitor projectorVisitor) {
        if (shardProjectionsIndex < 0) {
            return firstNodeProjector;
        }
        Projector previousProjector = firstNodeProjector;
        Projector projector = null;
        for (int i = shardProjectionsIndex; i >= 0; i--) {
            projector = projectorVisitor.process(projections.get(i));
            projector.downstream(previousProjector);
            shardProjectors.add(projector);
            previousProjector = projector;
        }
        return projector;
    }
View Full Code Here
124
125
126
127
128
129
130
131
132
133
134
     * collecting with this collector
     */
    public CrateCollector getCollector(CollectNode collectNode,
                                       ShardProjectorChain projectorChain) throws Exception {
        CollectNode normalizedCollectNode = collectNode.normalize(shardNormalizer);
        Projector downstream = projectorChain.newShardDownstreamProjector(projectorVisitor);

        if (normalizedCollectNode.whereClause().noMatch()) {
            return CrateCollector.NOOP;
        } else {
            RowGranularity granularity = normalizedCollectNode.maxRowGranularity();
View Full Code Here
TOP

Related Classes of io.crate.operation.projectors.Projector

  • io.crate.operation.collect.ShardCollectService
  • io.crate.operation.collect.ShardProjectorChain
  • io.crate.operation.collect.SimpleOneRowCollectorTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.