Package org.apache.flink.cdc.connectors.starrocks.sink

Class TableCreateConfig

java.lang.Object

org.apache.flink.cdc.connectors.starrocks.sink.TableCreateConfig

All Implemented Interfaces:

Serializable

public class TableCreateConfig
extends Object
implements Serializable

Configurations for creating a StarRocks table. See StarRocks Documentation for how to create a StarRocks primary key table.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_UNICODE_CHAR_BYTES	Maximum number of bytes a single character can take in UTF-8 encoding.

Constructor Summary

Constructors

Constructor	Description
TableCreateConfig(Integer numBuckets, Map<String,String> properties)
TableCreateConfig(Integer numBuckets, Map<String,String> properties, int unicodeCharMaxBytes)

Method Summary

Modifier and Type	Method	Description
static TableCreateConfig	from(Configuration config)
Optional<Integer>	getNumBuckets()
Map<String,String>	getProperties()
int	getUnicodeCharMaxBytes()

Methods inherited from class java.lang.Object

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

Field Detail

MAX_UNICODE_CHAR_BYTES

public static final int MAX_UNICODE_CHAR_BYTES

Maximum number of bytes a single character can take in UTF-8 encoding.

See Also:

Constant Field Values

Constructor Detail

TableCreateConfig

public TableCreateConfig(@Nullable
                         Integer numBuckets,
                         Map<String,String> properties)

TableCreateConfig

public TableCreateConfig(@Nullable
                         Integer numBuckets,
                         Map<String,String> properties,
                         int unicodeCharMaxBytes)

Method Detail

getNumBuckets

public Optional<Integer> getNumBuckets()

getProperties

public Map<String,String> getProperties()

getUnicodeCharMaxBytes

public int getUnicodeCharMaxBytes()

from

public static TableCreateConfig from(Configuration config)