org.apache.paimon.flink.clone

Class CloneUtils

java.lang.Object

org.apache.paimon.flink.clone.CloneUtils

public class CloneUtils
extends Object

Utils for building CloneAction.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CloneUtils.DataFileChannelComputer Shuffle tables.
static class	CloneUtils.TableChannelComputer Shuffle tables.

Constructor Summary

Constructors

Constructor and Description
CloneUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<Identifier,Identifier>>	buildSource(String sourceDatabase, String sourceTableName, String targetDatabase, String targetTableName, Catalog sourceCatalog, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
static HiveCatalog	getRootHiveCatalog(Catalog catalog)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CloneUtils

public CloneUtils()

Method Detail

buildSource

public static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<Identifier,Identifier>> buildSource(String sourceDatabase,
                                                                                                                                              String sourceTableName,
                                                                                                                                              String targetDatabase,
                                                                                                                                              String targetTableName,
                                                                                                                                              Catalog sourceCatalog,
                                                                                                                                              org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)
                                                                                                                                       throws Exception

Throws:

Exception

getRootHiveCatalog

public static HiveCatalog getRootHiveCatalog(Catalog catalog)