Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
acquamarin committed Oct 11, 2023
1 parent 8307340 commit 8b5ddbb
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions src/include/processor/operator/persistent/copy_to_parquet.h
Original file line number Diff line number Diff line change
Expand Up @@ -58,14 +58,11 @@ class CopyToParquet : public Sink {
info{std::move(info)}, localState{std::make_unique<CopyToParquetLocalState>()},
sharedState{std::move(sharedState)} {}

void initLocalStateInternal(ResultSet* resultSet, ExecutionContext* context) final;

void executeInternal(ExecutionContext* context) final;

inline void finalize(ExecutionContext* executionContext) final {
sharedState->writer->finalize();
}

void initLocalStateInternal(ResultSet* resultSet, ExecutionContext* context) final;
void executeInternal(ExecutionContext* context) final;
std::unique_ptr<PhysicalOperator> clone() final {
return std::make_unique<CopyToParquet>(resultSetDescriptor->copy(), info->copy(),
sharedState, children[0]->clone(), id, paramsString);
Expand Down

0 comments on commit 8b5ddbb

Please sign in to comment.