Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
   *
   *     http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 /*
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  *     http://www.apache.org/licenses/LICENSE-2.0
  *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package com.facebook.presto.operator;
 
 
 import java.util.List;
 
 // This class exists as template for code generation and for testing
 public class TwoChannelJoinProbe
         implements JoinProbe
 {
     public static class TwoChannelJoinProbeFactory
             implements JoinProbeFactory
     {
         private final List<Typetypes;
 
         public TwoChannelJoinProbeFactory(List<Typetypes)
         {
             this. = types;
         }
 
         @Override
         public JoinProbe createJoinProbe(LookupSource lookupSourcePage page)
         {
             return new TwoChannelJoinProbe(lookupSourcepage);
         }
     }
 
     private final LookupSource lookupSource;
     private final int positionCount;
     private final Type typeA;
     private final Type typeB;
     private final Block blockA;
     private final Block blockB;
     private final Block probeBlockA;
     private final Block probeBlockB;
     private final Block[] probeBlocks;
     private final Page probePage;
     private int position = -1;
 
     public TwoChannelJoinProbe(List<TypetypesLookupSource lookupSourcePage page)
     {
         this. = lookupSource;
         this. = page.getPositionCount();
         this. = types.get(0);
         this. = types.get(1);
         this. = page.getBlock(0);
         this. = page.getBlock(1);
         this. = ;
         this. = ;
         this. = new Block[2];
         [0] = ;
         [1] = ;
         this. = new Page();
     }
 
     @Override
     public int getChannelCount()
     {
         return 2;
     }
 
     @Override
     public void appendTo(PageBuilder pageBuilder)
     {
         .appendTo(pageBuilder.getBlockBuilder(0));
         .appendTo(pageBuilder.getBlockBuilder(1));
     }
 
     @Override
     public boolean advanceNextPosition()
    {
        ++;
        return  < ;
    }
    @Override
    public long getCurrentJoinPosition()
    {
        if (currentRowContainsNull()) {
            return -1;
        }
    }
    private boolean currentRowContainsNull()
    {
        if (.isNull()) {
            return true;
        }
        if (.isNull()) {
            return true;
        }
        return false;
    }
New to GrepCode? Check out our FAQ X