com._4paradigm.openmldb.synctool

Class FlinkTunnel

java.lang.Object

com._4paradigm.openmldb.synctool.FlinkTunnel

public class FlinkTunnel
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlinkTunnel.KeyBucketAssigner Use first field for buckets.

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeTunnel(int tid)
boolean	createTunnel(int tid, String sourcePath, String sinkPath)
String	genJobName(int tid)
static FlinkTunnel	getInstance()
org.apache.flink.api.common.JobStatus	getJobStatus(int tid)
boolean	recoverTunnel(int tid)

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static FlinkTunnel getInstance()

recoverTunnel

public boolean recoverTunnel(int tid)

createTunnel

public boolean createTunnel(int tid,
                            String sourcePath,
                            String sinkPath)

getJobStatus

public org.apache.flink.api.common.JobStatus getJobStatus(int tid)

close

public void close()

genJobName

public String genJobName(int tid)

closeTunnel

public void closeTunnel(int tid)