Inheritance diagram for scanner::internal::ColumnSink:

Public Member Functions
	ColumnSink (const SinkConfig &config)

void	new_stream (const std::vector< u8 > &args) override
	Called when the Sink is about to process a new stream. More...

void	write (const BatchedElements &input_columns) override
	Runs the Sink to write elements. More...

void	new_task (i32 table_id, i32 task_id, std::vector< ColumnType > column_types)

void	finished ()
	When this function returns, the data for all previous 'write' calls MUST BE durably written.

void	provide_column_info (const std::vector< bool > &compressed, const std::vector< FrameInfo > &frame_info)

Public Member Functions inherited from scanner::Sink
	Sink (const SinkConfig &config)

virtual void	validate (proto::Result *result)
	Checks if Sink arguments are valid. More...

virtual void	set_profiler (Profiler *profiler)
	For internal use.

Additional Inherited Members
Public Attributes inherited from scanner::Sink
Profiler *	profiler_ = nullptr

Member Function Documentation

void scanner::internal::ColumnSink::new_stream ( const std::vector< u8 > & args )

overridevirtual

Called when the Sink is about to process a new stream.

Parameters

args	the arguments that were bound to this output for this stream

Reimplemented from scanner::Sink.

void scanner::internal::ColumnSink::write ( const BatchedElements & input_columns )

overridevirtual

Runs the Sink to write elements.

Parameters

input_columns sink input, vector of elements produced by an Op

The documentation for this class was generated from the following files:

Public Member Functions