java/pig-galago/src/com/yahoo/pig/impl/physicalLayer/POLoad.java

   1 /*
   2  * Copyright (c) 2007 Yahoo! Inc.  All rights reserved.
   3  * See accompanying LICENSE file.
   4  */
   5 package com.yahoo.pig.impl.physicalLayer;
   6
   7 import java.io.IOException;
   8
   9 import com.yahoo.pig.StorageFunc;
  10 import com.yahoo.pig.data.Tuple;
  11 import com.yahoo.pig.PigServer.ExecType;
  12 import com.yahoo.pig.impl.io.FileLocalizer;
  13
  14 public class POLoad extends PhysicalOperator {
  15     String   filename;
  16     StorageFunc lf;
  17     boolean bound = false;
  18
  19     public POLoad(String filenameIn, StorageFunc lfIn, int outputType) {
  20         super(outputType);
  21         inputs = new PhysicalOperator[0];
  22
  23         filename = filenameIn;
  24         lf = lfIn;
  25     }
  26
  27     public boolean open(boolean continueFromLast) throws IOException {
  28         if (!bound){
  29                 lf.bindTo(FileLocalizer.open(ExecType.LOCAL, filename), 0, Long.MAX_VALUE);
  30                 bound = true;
  31         }
  32         return true;
  33     }
  34
  35     public Tuple getNext() throws IOException {
  36         return lf.getNext();
  37     }
  38
  39 }