Examples of MarkDistinctOperatorFactory

Examples of com.facebook.presto.operator.MarkDistinctOperator.MarkDistinctOperatorFactory

61
62
63
64
65
66
67
68
69
70
71
72
        List<Page> input = rowPagesBuilder(BIGINT)
                .addSequencePage(100, 0)
                .addSequencePage(100, 0)
                .build();

        OperatorFactory operatorFactory = new MarkDistinctOperatorFactory(0, ImmutableList.of(BIGINT), ImmutableList.of(0));
        Operator operator = operatorFactory.createOperator(driverContext);

        MaterializedResult.Builder expected = resultBuilder(driverContext.getSession(), BIGINT, BOOLEAN);
        for (int i = 0; i < 100; i++) {
            expected.row(i, true);
            expected.row(i, false);
View Full Code Here

Examples of com.facebook.presto.operator.MarkDistinctOperator.MarkDistinctOperatorFactory

537
538
539
540
541
542
543
544
                    .putAll(source.getLayout())
                    .put(node.getMarkerSymbol(), new Input(source.getLayout().size())).build();

            Optional<Integer> sampleWeightChannel = node.getSampleWeightSymbol().transform(source.channelGetter());

            MarkDistinctOperatorFactory operator = new MarkDistinctOperatorFactory(context.getNextOperatorId(), source.getTypes(), channels, sampleWeightChannel);
            return new PhysicalOperation(operator, outputMappings, source);
        }
View Full Code Here

Examples of com.facebook.presto.operator.MarkDistinctOperator.MarkDistinctOperatorFactory

453
454
455
456
457
458
459
460
            Map<Symbol, Input> outputMappings = ImmutableMap.<Symbol, Input>builder()
                    .putAll(source.getLayout())
                    .put(node.getMarkerSymbol(), new Input(source.getLayout().size()))
                    .build();

            MarkDistinctOperatorFactory operator = new MarkDistinctOperatorFactory(context.getNextOperatorId(), source.getTupleInfos(), channels);
            return new PhysicalOperation(operator, outputMappings, source);
        }
View Full Code Here

Examples of com.facebook.presto.operator.MarkDistinctOperator.MarkDistinctOperatorFactory

477
478
479
480
481
482
483
484
                    .putAll(source.getLayout())
                    .put(node.getMarkerSymbol(), new Input(source.getLayout().size())).build();

            Optional<Integer> sampleWeightChannel = node.getSampleWeightSymbol().transform(source.channelGetter());

            MarkDistinctOperatorFactory operator = new MarkDistinctOperatorFactory(context.getNextOperatorId(), source.getTupleInfos(), channels, sampleWeightChannel);
            return new PhysicalOperation(operator, outputMappings, source);
        }
View Full Code Here

Examples of com.facebook.presto.operator.MarkDistinctOperator.MarkDistinctOperatorFactory

534
535
536
537
538
539
540
541
                    .putAll(source.getLayout())
                    .put(node.getMarkerSymbol(), source.getLayout().size()).build();

            Optional<Integer> sampleWeightChannel = node.getSampleWeightSymbol().transform(source.channelGetter());

            MarkDistinctOperatorFactory operator = new MarkDistinctOperatorFactory(context.getNextOperatorId(), source.getTypes(), channels, sampleWeightChannel);
            return new PhysicalOperation(operator, outputMappings, source);
        }
View Full Code Here

Examples of com.facebook.presto.operator.MarkDistinctOperator.MarkDistinctOperatorFactory

66
67
68
69
70
71
72
73
74
75
76
77
                .addSequencePage(100, 0)
                .addSequencePage(100, 0)
                .build();
        input = appendSampleWeight(input, 2);

        OperatorFactory operatorFactory = new MarkDistinctOperatorFactory(0, ImmutableList.of(BIGINT, BIGINT), ImmutableList.of(0), Optional.of(1));
        Operator operator = operatorFactory.createOperator(driverContext);

        MaterializedResult.Builder expected = resultBuilder(driverContext.getSession(), BIGINT, BIGINT, BOOLEAN);
        for (int i = 0; i < 100; i++) {
            expected.row(i, 1, true);
            expected.row(i, 1, false);
View Full Code Here

Examples of com.facebook.presto.operator.MarkDistinctOperator.MarkDistinctOperatorFactory

88
89
90
91
92
93
94
95
96
97
98
99
        List<Page> input = rowPagesBuilder(BIGINT)
                .addSequencePage(100, 0)
                .addSequencePage(100, 0)
                .build();

        OperatorFactory operatorFactory = new MarkDistinctOperatorFactory(0, ImmutableList.of(BIGINT), ImmutableList.of(0), Optional.<Integer>absent());
        Operator operator = operatorFactory.createOperator(driverContext);

        MaterializedResult.Builder expected = resultBuilder(driverContext.getSession(), BIGINT, BOOLEAN);
        for (int i = 0; i < 100; i++) {
            expected.row(i, true);
            expected.row(i, false);
View Full Code Here

Examples of com.facebook.presto.operator.MarkDistinctOperator.MarkDistinctOperatorFactory

66
67
68
69
70
71
72
73
74
75
76
77
                .addSequencePage(100, 0)
                .addSequencePage(100, 0)
                .build();
        input = appendSampleWeight(input, 2);

        OperatorFactory operatorFactory = new MarkDistinctOperatorFactory(0, ImmutableList.of(BIGINT, BIGINT), ImmutableList.of(0), Optional.of(1));
        Operator operator = operatorFactory.createOperator(driverContext);

        MaterializedResult.Builder expected = resultBuilder(driverContext.getSession(), BIGINT, BIGINT, BOOLEAN);
        for (int i = 0; i < 100; i++) {
            expected.row(i, 1, true);
            expected.row(i, 1, false);
View Full Code Here

Examples of com.facebook.presto.operator.MarkDistinctOperator.MarkDistinctOperatorFactory

88
89
90
91
92
93
94
95
96
97
98
99
        List<Page> input = rowPagesBuilder(BIGINT)
                .addSequencePage(100, 0)
                .addSequencePage(100, 0)
                .build();

        OperatorFactory operatorFactory = new MarkDistinctOperatorFactory(0, ImmutableList.of(BIGINT), ImmutableList.of(0), Optional.<Integer>absent());
        Operator operator = operatorFactory.createOperator(driverContext);

        MaterializedResult.Builder expected = resultBuilder(driverContext.getSession(), BIGINT, BOOLEAN);
        for (int i = 0; i < 100; i++) {
            expected.row(i, true);
            expected.row(i, false);
View Full Code Here

Examples of com.facebook.presto.operator.MarkDistinctOperator.MarkDistinctOperatorFactory

524
525
526
527
528
529
530
531
                    .putAll(source.getLayout())
                    .put(node.getMarkerSymbol(), new Input(source.getLayout().size())).build();

            Optional<Integer> sampleWeightChannel = node.getSampleWeightSymbol().transform(source.channelGetter());

            MarkDistinctOperatorFactory operator = new MarkDistinctOperatorFactory(context.getNextOperatorId(), source.getTypes(), channels, sampleWeightChannel);
            return new PhysicalOperation(operator, outputMappings, source);
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.