java/pig-galago/src/com/yahoo/pig/impl/logicalLayer/LORead.java

   1 /*
   2  * Copyright (c) 2007 Yahoo! Inc.  All rights reserved.
   3  * See accompanying LICENSE file.
   4  */
   5 package com.yahoo.pig.impl.logicalLayer;
   6
   7 import com.yahoo.pig.impl.PigContext;
   8 import com.yahoo.pig.impl.logicalLayer.schema.SchemaItemList;
   9 import com.yahoo.pig.impl.physicalLayer.IntermedResult;
  10
  11
  12 public class LORead extends LogicalOperator {
  13     public IntermedResult readFrom = null;
  14
  15         public LORead(PigContext pigContext, IntermedResult readFromIn) {
  16                 super(pigContext);
  17                 inputs = new LogicalOperator[0];
  18
  19         readFrom = readFromIn;
  20         }
  21         public String name() {
  22                 return "Read";
  23         }
  24         public String arguments() {
  25                 return alias;
  26         }
  27
  28     public SchemaItemList outputSchema() {
  29         if (schema == null) {
  30             if (readFrom.lp != null && readFrom.lp.root != null && readFrom.lp.root.outputSchema() != null) {
  31                 schema = readFrom.lp.root.outputSchema().copy();
  32             } else {
  33                 schema = new SchemaItemList();
  34             }
  35         }
  36
  37         schema.alias = alias;
  38
  39         return schema;
  40     }
  41
  42
  43
  44         public int getOutputType(){
  45                 return readFrom.getOutputType();
  46         }
  47 }