DiffluenceExecStream.cpp

Go to the documentation of this file.
00001 /*
00002 // $Id: //open/dev/fennel/exec/DiffluenceExecStream.cpp#7 $
00003 // Fennel is a library of data storage and processing components.
00004 // Copyright (C) 2005-2009 The Eigenbase Project
00005 // Copyright (C) 2005-2009 SQLstream, Inc.
00006 // Copyright (C) 2005-2009 LucidEra, Inc.
00007 // Portions Copyright (C) 2004-2009 John V. Sichi
00008 //
00009 // This program is free software; you can redistribute it and/or modify it
00010 // under the terms of the GNU General Public License as published by the Free
00011 // Software Foundation; either version 2 of the License, or (at your option)
00012 // any later version approved by The Eigenbase Project.
00013 //
00014 // This program is distributed in the hope that it will be useful,
00015 // but WITHOUT ANY WARRANTY; without even the implied warranty of
00016 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
00017 // GNU General Public License for more details.
00018 //
00019 // You should have received a copy of the GNU General Public License
00020 // along with this program; if not, write to the Free Software
00021 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
00022 */
00023 
00024 #include "fennel/common/CommonPreamble.h"
00025 #include "fennel/exec/DiffluenceExecStream.h"
00026 #include "fennel/exec/ExecStreamBufAccessor.h"
00027 #include "fennel/exec/ExecStreamGraph.h"
00028 
00029 FENNEL_BEGIN_CPPFILE("$Id: //open/dev/fennel/exec/DiffluenceExecStream.cpp#7 $");
00030 
00031 DiffluenceExecStreamParams::DiffluenceExecStreamParams()
00032 {
00033     outputTupleFormat = TUPLE_FORMAT_STANDARD;
00034 }
00035 
00036 void DiffluenceExecStream::setOutputBufAccessors(
00037     std::vector<SharedExecStreamBufAccessor> const &outAccessorsInit)
00038 {
00039     outAccessors = outAccessorsInit;
00040 }
00041 
00042 void DiffluenceExecStream::prepare(DiffluenceExecStreamParams const &params)
00043 {
00044     SingleInputExecStream::prepare(params);
00045 
00046     // By default, shape for all outputs is the same as the input if the
00047     // outputTupleDesc wasn't explicitly set.
00048     TupleDescriptor tupleDesc;
00049     TupleFormat tupleFormat;
00050     if (params.outputTupleDesc.empty()) {
00051         tupleDesc = pInAccessor->getTupleDesc();
00052         tupleFormat = pInAccessor->getTupleFormat();
00053     } else {
00054         tupleDesc = params.outputTupleDesc;
00055         tupleFormat = params.outputTupleFormat;
00056     }
00057     for (uint i = 0; i < outAccessors.size(); ++i) {
00058         assert(outAccessors[i]->getProvision() == getOutputBufProvision());
00059         outAccessors[i]->setTupleShape(tupleDesc, tupleFormat);
00060     }
00061 }
00062 
00063 void DiffluenceExecStream::open(bool restart)
00064 {
00065     SingleInputExecStream::open(restart);
00066 
00067     if (restart) {
00068         // restart outputs
00069         for (uint i = 0; i < outAccessors.size(); ++i) {
00070             outAccessors[i]->clear();
00071         }
00072     }
00073 }
00074 
00075 ExecStreamBufProvision DiffluenceExecStream::getOutputBufProvision() const
00076 {
00077     /*
00078      * Indicate to the consumer that buffer should be provided by the consumer.
00079      * By default, DiffluenceExecStream does not have any associated buffers.
00080      */
00081     return BUFPROV_CONSUMER;
00082 }
00083 
00084 
00085 FENNEL_END_CPPFILE("$Id: //open/dev/fennel/exec/DiffluenceExecStream.cpp#7 $");
00086 
00087 // End DiffluenceExecStream.cpp

Generated on Mon Jun 22 04:00:18 2009 for Fennel by  doxygen 1.5.1