Package io.github.flink.gcp.connector.bigtable.table

Class SelectedCellTableSchema

java.lang.Object

io.github.flink.gcp.connector.bigtable.table.SelectedCellTableSchema

@Internal
public final class SelectedCellTableSchema
extends Object

The physical primary key and value-format payload of a selected-cell table.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object other)
org.apache.flink.table.types.DataType	getPayloadDataType()
org.apache.flink.table.types.DataType	getPhysicalDataType()
int	getPrimaryKeyIndex()
org.apache.flink.table.types.logical.LogicalType	getPrimaryKeyType()
int	hashCode()
static SelectedCellTableSchema	of(org.apache.flink.table.types.DataType physicalDataType, int[] primaryKeyIndexes)	Derives the format payload by removing the one declared primary-key field.

Methods inherited from class java.lang.Object

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

Method Details

of

public static SelectedCellTableSchema of(org.apache.flink.table.types.DataType physicalDataType,
 int[] primaryKeyIndexes)

Derives the format payload by removing the one declared primary-key field.

getPhysicalDataType

public org.apache.flink.table.types.DataType getPhysicalDataType()

getPayloadDataType

public org.apache.flink.table.types.DataType getPayloadDataType()

getPrimaryKeyIndex

public int getPrimaryKeyIndex()

getPrimaryKeyType

public org.apache.flink.table.types.logical.LogicalType getPrimaryKeyType()

equals

public boolean equals(Object other)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object