org.apache.paimon.flink.clone

Class CloneSourceBuilder

java.lang.Object

org.apache.paimon.flink.clone.CloneSourceBuilder

public class CloneSourceBuilder
extends Object

Pick the tables to be cloned based on the user input parameters. The record type of the build DataStream is Tuple2. The left element is the identifier of source table and the right element is the identifier of target table.

Constructor Summary

Constructors

Constructor and Description
CloneSourceBuilder(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, Map<String,String> sourceCatalogConfig, String database, String tableName, String targetDatabase, String targetTableName)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<String,String>>	build()

Methods inherited from class java.lang.Object

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

Constructor Detail

CloneSourceBuilder

public CloneSourceBuilder(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
                          Map<String,String> sourceCatalogConfig,
                          String database,
                          String tableName,
                          String targetDatabase,
                          String targetTableName)

Method Detail

build

public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.api.java.tuple.Tuple2<String,String>> build()
                                                                                                                  throws Exception

Throws:

Exception