You've already forked mariadb-columnstore-engine
mirror of
https://github.com/mariadb-corporation/mariadb-columnstore-engine.git
synced 2025-10-30 07:25:34 +03:00
113 lines
3.3 KiB
C++
113 lines
3.3 KiB
C++
/* Copyright (C) 2014 InfiniDB, Inc.
|
|
|
|
This program is free software; you can redistribute it and/or
|
|
modify it under the terms of the GNU General Public License
|
|
as published by the Free Software Foundation; version 2 of
|
|
the License.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
|
|
MA 02110-1301, USA. */
|
|
|
|
#include "pseudocc-jl.h"
|
|
#include "pseudocolumn.h"
|
|
#include "nullvaluemanip.h"
|
|
|
|
using namespace std;
|
|
using namespace messageqcpp;
|
|
using namespace execplan;
|
|
|
|
namespace joblist
|
|
{
|
|
PseudoCCJL::PseudoCCJL(const PseudoColStep& pcs) : ColumnCommandJL(pcs), function(pcs.pseudoColumnId())
|
|
{
|
|
}
|
|
|
|
PseudoCCJL::~PseudoCCJL()
|
|
{
|
|
}
|
|
|
|
void PseudoCCJL::createCommand(ByteStream& bs) const
|
|
{
|
|
bs << (uint8_t)PSEUDO_COLUMN;
|
|
bs << function;
|
|
ColumnCommandJL::createCommand(bs);
|
|
}
|
|
|
|
void PseudoCCJL::runCommand(ByteStream& bs) const
|
|
{
|
|
if (function == PSEUDO_EXTENTMAX)
|
|
{
|
|
if (!colType.isWideDecimalType())
|
|
{
|
|
int64_t max = extents[currentExtentIndex].partition.cprange.hiVal;
|
|
int64_t min = extents[currentExtentIndex].partition.cprange.loVal;
|
|
|
|
if (extents[currentExtentIndex].partition.cprange.isValid == BRM::CP_VALID && max >= min)
|
|
bs << max;
|
|
else
|
|
bs << utils::getNullValue(colType.colDataType, colType.colWidth);
|
|
}
|
|
else
|
|
{
|
|
int128_t max = extents[currentExtentIndex].partition.cprange.bigHiVal;
|
|
int128_t min = extents[currentExtentIndex].partition.cprange.bigLoVal;
|
|
|
|
if (extents[currentExtentIndex].partition.cprange.isValid == BRM::CP_VALID && max >= min)
|
|
bs << (uint128_t)max;
|
|
else
|
|
{
|
|
int128_t int128Null;
|
|
datatypes::Decimal::setWideDecimalNullValue(int128Null);
|
|
bs << (uint128_t)int128Null;
|
|
}
|
|
}
|
|
}
|
|
else if (function == PSEUDO_EXTENTMIN)
|
|
{
|
|
if (!colType.isWideDecimalType())
|
|
{
|
|
int64_t max = extents[currentExtentIndex].partition.cprange.hiVal;
|
|
int64_t min = extents[currentExtentIndex].partition.cprange.loVal;
|
|
|
|
if (extents[currentExtentIndex].partition.cprange.isValid == BRM::CP_VALID && max >= min)
|
|
bs << min;
|
|
else
|
|
bs << utils::getNullValue(colType.colDataType, colType.colWidth);
|
|
}
|
|
else
|
|
{
|
|
int128_t max = extents[currentExtentIndex].partition.cprange.bigHiVal;
|
|
int128_t min = extents[currentExtentIndex].partition.cprange.bigLoVal;
|
|
|
|
if (extents[currentExtentIndex].partition.cprange.isValid == BRM::CP_VALID && max >= min)
|
|
bs << (uint128_t)min;
|
|
else
|
|
{
|
|
int128_t int128Null;
|
|
datatypes::Decimal::setWideDecimalNullValue(int128Null);
|
|
bs << (uint128_t)int128Null;
|
|
}
|
|
}
|
|
}
|
|
else if (function == PSEUDO_EXTENTID)
|
|
bs << extents[currentExtentIndex].range.start;
|
|
|
|
ColumnCommandJL::runCommand(bs);
|
|
}
|
|
|
|
string PseudoCCJL::toString()
|
|
{
|
|
ostringstream oss;
|
|
oss << "PseudoColumnJL fcn: " << function << " on: " << ColumnCommandJL::toString();
|
|
return oss.str();
|
|
}
|
|
|
|
} // namespace joblist
|