Modifier and Type | Method and Description |
---|---|
T |
ModifyOperationVisitor.visit(CatalogSinkModifyOperation catalogSink) |
Modifier and Type | Method and Description |
---|---|
CatalogSinkModifyOperation |
CreateTableASOperation.getInsertOperation() |
Constructor and Description |
---|
CreateTableASOperation(CreateTableOperation createTableOperation,
CatalogSinkModifyOperation insertOperation) |
Modifier and Type | Method and Description |
---|---|
static org.apache.calcite.rel.RelNode |
DynamicSinkUtils.convertSinkToRel(org.apache.flink.table.planner.calcite.FlinkRelBuilder relBuilder,
org.apache.calcite.rel.RelNode input,
CatalogSinkModifyOperation sinkModifyOperation,
DynamicTableSink sink,
ResolvedCatalogTable table)
Converts a given
DynamicTableSink to a RelNode . |
Modifier and Type | Method and Description |
---|---|
CatalogSinkModifyOperation |
HiveParserDMLHelper.createInsertOperation(org.apache.calcite.rel.RelNode queryRelNode,
org.apache.hadoop.hive.ql.metadata.Table destTable,
Map<String,String> staticPartSpec,
List<String> destSchema,
boolean overwrite) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.