public class MigrateFileProcedure extends ProcedureBase
catalog
Constructor and Description |
---|
MigrateFileProcedure() |
Modifier and Type | Method and Description |
---|---|
String[] |
call(org.apache.flink.table.procedure.ProcedureContext procedureContext,
String connector,
String sourceTablePath,
String targetPaimonTablePath,
Boolean deleteOrigin,
Integer parallelism) |
String |
identifier()
Returns a unique identifier among same factory interfaces.
|
void |
migrateHandle(String connector,
String sourceTablePath,
String targetPaimonTablePath,
boolean deleteOrigin,
Integer parallelism) |
execute, execute, execute, notnull, nullable, optionalConfigMap, table, withCatalog
public String identifier()
Factory
For consistency, an identifier should be declared as one lower case word (e.g. kafka
). If multiple factories exist for different versions, a version should be appended
using "-" (e.g. elasticsearch-7
).
public String[] call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String connector, String sourceTablePath, String targetPaimonTablePath, Boolean deleteOrigin, Integer parallelism) throws Exception
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.