Package com.facebook.presto.byteCode

Examples of com.facebook.presto.byteCode.Block.pushThis()


                    .putField(cursorFields.get(index));
        }

        constructor.comment("Set probe channel fields");
        for (int index = 0; index < probeChannelFields.size(); index++) {
            constructor
                    .pushThis()
                    .pushThis()
                    .getField(cursorFields.get(probeChannels.get(index)))
                    .putField(probeChannelFields.get(index));
        }
View Full Code Here


                    .getField(cursorFields.get(probeChannels.get(index)))
                    .putField(probeChannelFields.get(index));
        }

        constructor.comment("this.probeCursors = new BlockCursor[<probeChannelCount>];");
        constructor
                .pushThis()
                .push(probeChannelFields.size())
                .newArray(BlockCursor.class)
                .putField(probeCursorsArrayField);
        for (int index = 0; index < probeChannelFields.size(); index++) {
View Full Code Here

                .pushThis()
                .push(probeChannelFields.size())
                .newArray(BlockCursor.class)
                .putField(probeCursorsArrayField);
        for (int index = 0; index < probeChannelFields.size(); index++) {
            constructor
                    .pushThis()
                    .getField(probeCursorsArrayField)
                    .push(index)
                    .pushThis()
                    .getField(probeChannelFields.get(index))
View Full Code Here

                type(void.class),
                arg("pageBuilder", PageBuilder.class))
                .getBody();

        for (int index = 0; index < cursorFields.size(); index++) {
            appendToBody
                    .pushThis()
                    .getField(cursorFields.get(index))
                    .getVariable("pageBuilder")
                    .push(index)
                    .invokeVirtual(PageBuilder.class, "getBlockBuilder", BlockBuilder.class, int.class)
View Full Code Here

                "advanceNextPosition",
                type(boolean.class))
                .getBody();
        LocalVariableDefinition advancedVariable = compilerContext.declareVariable(boolean.class, "advanced");

        advanceNextPositionBody
                .pushThis()
                .getField(cursorFields.get(0))
                .invokeInterface(BlockCursor.class, "advanceNextPosition", boolean.class)
                .putVariable(advancedVariable);
View Full Code Here

                .getField(cursorFields.get(0))
                .invokeInterface(BlockCursor.class, "advanceNextPosition", boolean.class)
                .putVariable(advancedVariable);

        for (int index = 1; index < cursorFields.size(); index++) {
            advanceNextPositionBody
                    .pushThis()
                    .getField(cursorFields.get(index))
                    .invokeInterface(BlockCursor.class, "advanceNextPosition", boolean.class)
                    .getVariable(advancedVariable)
                    .invokeStatic(JoinProbeCompiler.class, "checkState", void.class, boolean.class, boolean.class);
View Full Code Here

                type(boolean.class))
                .getBody();

        for (FieldDefinition probeCursorField : probeCursorFields) {
            LabelNode checkNextField = new LabelNode("checkNextField");
            body
                    .pushThis()
                    .getField(probeCursorField)
                    .invokeInterface(BlockCursor.class, "isNull", boolean.class)
                    .ifFalseGoto(checkNextField)
                    .push(true)
View Full Code Here

                .pushThis()
                .invokeConstructor(Object.class);

        constructor.comment("Set channel fields");
        for (int index = 0; index < channelFields.size(); index++) {
            constructor
                    .pushThis()
                    .getVariable("channels")
                    .push(index)
                    .invokeInterface(List.class, "get", Object.class, int.class)
                    .checkCast(type(List.class, RandomAccessBlock.class))
View Full Code Here

                    .putField(channelFields.get(index));
        }

        constructor.comment("Set join channel fields");
        for (int index = 0; index < joinChannelFields.size(); index++) {
            constructor
                    .pushThis()
                    .getVariable("channels")
                    .push(joinChannels.get(index))
                    .invokeInterface(List.class, "get", Object.class, int.class)
                    .checkCast(type(List.class, RandomAccessBlock.class))
View Full Code Here

                arg("pageBuilder", PageBuilder.class),
                arg("outputChannelOffset", int.class))
                .getBody();

        for (int index = 0; index < channelFields.size(); index++) {
            appendToBody.pushThis()
                    .getField(channelFields.get(index))
                    .getVariable("blockIndex")
                    .invokeInterface(List.class, "get", Object.class, int.class)
                    .checkCast(RandomAccessBlock.class)
                    .getVariable("blockPosition")
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.