org.apache.iceberg.connect.events

Class TableReference

java.lang.Object

org.apache.iceberg.connect.events.TableReference

All Implemented Interfaces:

org.apache.avro.generic.GenericContainer, org.apache.avro.generic.IndexedRecord

public class TableReference
extends java.lang.Object
implements org.apache.avro.generic.IndexedRecord

Element representing a table identifier, with namespace and name.

Field Summary

Fields

Modifier and Type	Field and Description
static Types.StructType	ICEBERG_SCHEMA

Constructor Summary

Constructors

Constructor and Description
TableReference(org.apache.avro.Schema avroSchema)
TableReference(java.lang.String catalog, java.util.List<java.lang.String> namespace, java.lang.String name)

Method Summary

Modifier and Type	Method and Description
java.lang.String	catalog()
java.lang.Object	get(int i)
org.apache.avro.Schema	getSchema()
TableIdentifier	identifier()
static TableReference	of(java.lang.String catalog, TableIdentifier tableIdentifier)
void	put(int i, java.lang.Object v)

Methods inherited from class java.lang.Object

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

Field Detail

ICEBERG_SCHEMA

public static final Types.StructType ICEBERG_SCHEMA

Constructor Detail

TableReference

public TableReference(org.apache.avro.Schema avroSchema)

TableReference

public TableReference(java.lang.String catalog,
                      java.util.List<java.lang.String> namespace,
                      java.lang.String name)

Method Detail

of

public static TableReference of(java.lang.String catalog,
                                TableIdentifier tableIdentifier)

catalog

public java.lang.String catalog()

identifier

public TableIdentifier identifier()

getSchema

public org.apache.avro.Schema getSchema()

Specified by:

getSchema in interface org.apache.avro.generic.GenericContainer

put

public void put(int i,
                java.lang.Object v)

Specified by:

put in interface org.apache.avro.generic.IndexedRecord

get

public java.lang.Object get(int i)

Specified by:

get in interface org.apache.avro.generic.IndexedRecord