ClickHouse/dbms/src/Processors/ISimpleTransform.h

#pragma once

#include <Processors/IProcessor.h>


namespace DB
{

/** Has one input and one output.
  * Simply pull a block from input, transform it, and push it to output.
  */
class ISimpleTransform : public IProcessor
{
protected:
    InputPort & input;
    OutputPort & output;

    Chunk current_chunk;
    bool has_input = false;
    bool transformed = false;
    const bool skip_empty_chunks;

    virtual void transform(Chunk & chunk) = 0;

public:
    ISimpleTransform(Block input_header, Block output_header, bool skip_empty_chunks);

    Status prepare() override;
    void work() override;

    InputPort & getInputPort() { return input; }
    OutputPort & getOutputPort() { return output; }
};

}