class ExchangeOperator implements SourceOperator {

    @Override
    public void finish()
    {
        close();
    }

    public  ExchangeOperator(
            OperatorContext operatorContext,
            PlanNodeId sourceId,
            PagesSerde serde,
            ExchangeClient exchangeClient);

}