language-extensions/R/src/RSession.cpp
//--------------------------------------------------------------------------------------------------
// Name: RSession::Init
//
// Description:
//  Initializes the input column for this session
//
:Init
Description:
Initializes the input column for this session
: Init Description : Initializes the input column for this session
void RSession::InitColumn(
	SQLUSMALLINT  columnNumber,
	const SQLCHAR *columnName,
	SQLSMALLINT   columnNameLength,
	SQLSMALLINT   dataType,
	SQLULEN       columnSize,
	SQLSMALLINT   decimalDigits,
	SQLSMALLINT   nullable,
	SQLSMALLINT   partitionByNumber,
	SQLSMALLINT   orderByNumber)
{
	LOG("RSession::InitColumn " + to_string(columnNumber));
	if (!m_isStreaming && partitionByNumber != -1)
	{
		m_isStreaming = true;
		m_outputDataSet.IsStreaming(true);
	}
	m_inputDataSet.InitColumn(
		columnNumber,
		columnName,
		columnNameLength,
		dataType,
		columnSize,
		decimalDigits,
		nullable);
}
void RSession :: InitColumn ( SQLUSMALLINT columnNumber , const SQLCHAR * columnName , SQLSMALLINT columnNameLength , SQLSMALLINT dataType , SQLULEN columnSize , SQLSMALLINT decimalDigits , SQLSMALLINT nullable , SQLSMALLINT partitionByNumber , SQLSMALLINT orderByNumber ) { LOG ( " " + to_string ( columnNumber ) ) ; if ( ! m_isStreaming && partitionByNumber != -1 ) { m_isStreaming = true ; m_outputDataSet . IsStreaming ( true ) ; } m_inputDataSet . InitColumn ( columnNumber , columnName , columnNameLength , dataType , columnSize , decimalDigits , nullable ) ; }
Name: RSession::Init
Description:
Initializes the input column for this session
Name : RSession :: Init Description : Initializes the input column for this session
// Check if we are streaming.  // If partitionByNumber is set, we are in the partitioning case,  // which works the same way as streaming - each partition comes in as a separate // chunk and we need to clear the output data set in between each. //