[Feature](Routine Load)Support Partial Update #22785
Conversation
CalvinKirs
force-pushed
the
master-partial_columns-routine-load
branch
from
bb19616
to
7a0f5f8
Compare
CalvinKirs
force-pushed
the
master-partial_columns-routine-load
branch
from
f2ac103
to
a57cb86
Compare
|
run buildall |
| } | ||
| Database db = Env.getCurrentInternalCatalog().getDbOrAnalysisException(job.getDbFullName()); | ||
| Table table = db.getTableOrAnalysisException(job.getTableName()); | ||
| if (isPartialUpdate && ((OlapTable) table).getKeysType() != KeysType.UNIQUE_KEYS) { |
There was a problem hiding this comment.
should use !((OlapTable) table).getEnableUniqueKeyMergeOnWrite()
| Database db = Env.getCurrentInternalCatalog().getDbOrAnalysisException(job.getDbFullName()); | ||
| Table table = db.getTableOrAnalysisException(job.getTableName()); | ||
| if (isPartialUpdate && ((OlapTable) table).getKeysType() != KeysType.UNIQUE_KEYS) { | ||
| throw new AnalysisException("load by PARTIAL_COLUMNS is only supported in unique tables."); |
| @@ -339,6 +353,9 @@ public void checkDBTable(Analyzer analyzer) throws AnalysisException { | |||
| && !(table.getType() == Table.TableType.OLAP && ((OlapTable) table).hasDeleteSign())) { | |||
| throw new AnalysisException("load by MERGE or DELETE need to upgrade table to support batch delete."); | |||
| } | |||
| if (isPartialUpdate && ((OlapTable) table).getKeysType() != KeysType.UNIQUE_KEYS) { | |||
|
run buildall |
github-actions
bot
added
the
approved
|
PR approved by at least one committer and no changes requested. |
|
PR approved by anyone and no changes requested. |
|
run clickbench-new (clickbench) |
|
(From new machine)TeamCity pipeline, clickbench performance test result: |
|
run P0 |
(cherry picked from commit 221e860)
Proposed changes
Issue Number: close #xxx
Further comments
If this is a relatively large or complex change, kick off the discussion at [email protected] by explaining why you chose the solution you did and what alternatives you considered, etc...