Package edu.caltech.nanodb.server

Class TupleSender

  • All Implemented Interfaces:
    TupleProcessor
    public class TupleSender
extends java.lang.Object
implements TupleProcessor
    This implementation of the tuple-processor interface sends the schema and tuples produced by the SELECT statement over an ObjectOutputStream.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private java.io.ObjectOutputStream objectOutput  

    • Constructor Summary

      Constructors 
      Constructor Description
      TupleSender​(java.io.ObjectOutputStream objectOutput)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void finish()
      This function is called when all tuples have been produced and passed to the tuple processor.
      void process​(Tuple tuple)
      Processes a single tuple generated from evaluating a query plan.
      void setSchema​(Schema schema)
      This method is called once by the query evaluator before any tuples are passed to the TupleProcessor.process(edu.caltech.nanodb.relations.Tuple) method, so that the tuple-processor knows what the expected tuple-schema will be.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • objectOutput

        private java.io.ObjectOutputStream objectOutput

    • Constructor Detail

      • TupleSender

        public TupleSender​(java.io.ObjectOutputStream objectOutput)