1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.sqlfederation.optimizer.operator.physical;
19
20 import org.apache.calcite.adapter.enumerable.EnumerableRel;
21 import org.apache.calcite.adapter.enumerable.EnumerableRelImplementor;
22 import org.apache.calcite.plan.RelOptCluster;
23 import org.apache.calcite.plan.RelOptTable;
24 import org.apache.calcite.plan.RelTraitSet;
25 import org.apache.calcite.prepare.Prepare.CatalogReader;
26 import org.apache.calcite.rel.RelNode;
27 import org.apache.calcite.rel.core.TableModify;
28 import org.apache.calcite.rex.RexNode;
29
30 import java.util.List;
31
32
33
34
35 public final class EnumerableModify extends TableModify implements EnumerableRel {
36
37 public EnumerableModify(final RelOptCluster cluster, final RelTraitSet traitSet, final RelOptTable table, final CatalogReader catalogReader,
38 final RelNode input, final Operation operation, final List<String> updateColumnList, final List<RexNode> sourceExpressionList, final boolean flattened) {
39 super(cluster, traitSet, table, catalogReader, input, operation, updateColumnList, sourceExpressionList, flattened);
40 }
41
42 @Override
43 public RelNode copy(final RelTraitSet traitSet, final List<RelNode> inputs) {
44 return new EnumerableModify(getCluster(), traitSet, getTable(), getCatalogReader(), sole(inputs), getOperation(), getUpdateColumnList(), getSourceExpressionList(), isFlattened());
45 }
46
47 @Override
48 public Result implement(final EnumerableRelImplementor implementor, final Prefer prefer) {
49
50 throw new UnsupportedOperationException();
51 }
52 }