Package org.apache.flink.cdc.connectors.maxcompute.options

Class MaxComputeOptions

java.lang.Object

org.apache.flink.cdc.connectors.maxcompute.options.MaxComputeOptions

All Implemented Interfaces:

Serializable

public class MaxComputeOptions
extends Object
implements Serializable

basic options for MaxCompute.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MaxComputeOptions.Builder	builder for maxcompute options.

Method Summary

Modifier and Type	Method	Description
static MaxComputeOptions.Builder	builder(String accessId, String accessKey, String endpoint, String project)
String	getAccessId()
String	getAccessKey()
int	getBucketsNum()
String	getEndpoint()
String	getProject()
String	getQuotaName()
String	getSchemaOperatorUid()
String	getStsToken()
String	getTunnelEndpoint()
boolean	isSupportSchema()

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static MaxComputeOptions.Builder builder(String accessId,
                                                String accessKey,
                                                String endpoint,
                                                String project)

getTunnelEndpoint

public String getTunnelEndpoint()

getAccessId

public String getAccessId()

getAccessKey

public String getAccessKey()

getEndpoint

public String getEndpoint()

getProject

public String getProject()

getQuotaName

public String getQuotaName()

getStsToken

public String getStsToken()

isSupportSchema

public boolean isSupportSchema()

getBucketsNum

public int getBucketsNum()

getSchemaOperatorUid

public String getSchemaOperatorUid()