Uses of Class
org.apache.flink.table.catalog.ObjectIdentifier

Packages that use ObjectIdentifier

Package	Description
org.apache.flink.table.api.internal
org.apache.flink.table.api.java.internal
org.apache.flink.table.catalog
org.apache.flink.table.functions
org.apache.flink.table.operations
org.apache.flink.table.operations.ddl
org.apache.flink.table.planner.catalog
org.apache.flink.table.planner.operations
org.apache.flink.table.types.logical

Uses of ObjectIdentifier in org.apache.flink.table.api.internal

Methods in org.apache.flink.table.api.internal with parameters of type ObjectIdentifier

Modifier and Type	Method and Description
protected QueryOperation	TableEnvironmentImpl.qualifyQueryOperation(ObjectIdentifier identifier, QueryOperation queryOperation) Subclasses can override this method to transform the given QueryOperation to a new one with the qualified object identifier.

Uses of ObjectIdentifier in org.apache.flink.table.api.java.internal

Methods in org.apache.flink.table.api.java.internal with parameters of type ObjectIdentifier

Modifier and Type	Method and Description
protected QueryOperation	StreamTableEnvironmentImpl.qualifyQueryOperation(ObjectIdentifier identifier, QueryOperation queryOperation)

Uses of ObjectIdentifier in org.apache.flink.table.catalog

Methods in org.apache.flink.table.catalog that return ObjectIdentifier

Modifier and Type	Method and Description
static ObjectIdentifier	ObjectIdentifier.of(String catalogName, String databaseName, String objectName)
ObjectIdentifier	CatalogManager.qualifyIdentifier(UnresolvedIdentifier identifier) Returns the full name of the given table path, this name may be padded with current catalog/database name based on the identifier's length.

Methods in org.apache.flink.table.catalog with parameters of type ObjectIdentifier

Modifier and Type	Method and Description
void	CatalogManager.alterTable(CatalogBaseTable table, ObjectIdentifier objectIdentifier, boolean ignoreIfNotExists) Alters a table in a given fully qualified path.
void	CatalogManager.createTable(CatalogBaseTable table, ObjectIdentifier objectIdentifier, boolean ignoreIfExists) Creates a table in a given fully qualified path.
void	CatalogManager.createTemporaryTable(CatalogBaseTable table, ObjectIdentifier objectIdentifier, boolean replace) Creates a temporary table in a given fully qualified path.
void	CatalogManager.dropTable(ObjectIdentifier objectIdentifier, boolean ignoreIfNotExists) Drops a table in a given fully qualified path.
void	FunctionCatalog.dropTempCatalogFunction(ObjectIdentifier identifier, boolean ignoreIfNotExist) Drop a temporary catalog function.
Optional<CatalogManager.TableLookupResult>	CatalogManager.getTable(ObjectIdentifier objectIdentifier) Retrieves a fully qualified table.
boolean	FunctionCatalog.hasTemporaryCatalogFunction(ObjectIdentifier functionIdentifier) Check whether a temporary catalog function is already registered.
<T,ACC> void	FunctionCatalog.registerTempCatalogAggregateFunction(ObjectIdentifier oi, UserDefinedAggregateFunction<T,ACC> function, TypeInformation<T> resultType, TypeInformation<ACC> accType)
void	FunctionCatalog.registerTempCatalogScalarFunction(ObjectIdentifier oi, ScalarFunction function)
<T> void	FunctionCatalog.registerTempCatalogTableFunction(ObjectIdentifier oi, TableFunction<T> function, TypeInformation<T> resultType)

Uses of ObjectIdentifier in org.apache.flink.table.functions

Methods in org.apache.flink.table.functions that return ObjectIdentifier

Modifier and Type	Method and Description
static ObjectIdentifier	FunctionIdentifier.normalizeObjectIdentifier(ObjectIdentifier oi) Normalize an object identifier by only normalizing the function name.

Methods in org.apache.flink.table.functions that return types with arguments of type ObjectIdentifier

Modifier and Type	Method and Description
Optional<ObjectIdentifier>	FunctionIdentifier.getIdentifier()

Methods in org.apache.flink.table.functions with parameters of type ObjectIdentifier

Modifier and Type	Method and Description
static ObjectIdentifier	FunctionIdentifier.normalizeObjectIdentifier(ObjectIdentifier oi) Normalize an object identifier by only normalizing the function name.
static FunctionIdentifier	FunctionIdentifier.of(ObjectIdentifier oi)

Uses of ObjectIdentifier in org.apache.flink.table.operations

Methods in org.apache.flink.table.operations that return ObjectIdentifier

Modifier and Type	Method and Description
ObjectIdentifier	CatalogQueryOperation.getTableIdentifier()
ObjectIdentifier	CatalogSinkModifyOperation.getTableIdentifier()

Methods in org.apache.flink.table.operations that return types with arguments of type ObjectIdentifier

Modifier and Type	Method and Description
Optional<ObjectIdentifier>	ScalaDataStreamQueryOperation.getIdentifier()
Optional<ObjectIdentifier>	JavaDataStreamQueryOperation.getIdentifier()

Constructors in org.apache.flink.table.operations with parameters of type ObjectIdentifier

Constructor and Description
CatalogQueryOperation(ObjectIdentifier tableIdentifier, TableSchema tableSchema)
CatalogSinkModifyOperation(ObjectIdentifier tableIdentifier, QueryOperation child)
CatalogSinkModifyOperation(ObjectIdentifier tableIdentifier, QueryOperation child, Map<String,String> staticPartitions, boolean overwrite)
JavaDataStreamQueryOperation(ObjectIdentifier identifier, DataStream<E> dataStream, int[] fieldIndices, TableSchema tableSchema)
ScalaDataStreamQueryOperation(ObjectIdentifier identifier, DataStream<E> dataStream, int[] fieldIndices, TableSchema tableSchema)

Uses of ObjectIdentifier in org.apache.flink.table.operations.ddl

Fields in org.apache.flink.table.operations.ddl declared as ObjectIdentifier

Modifier and Type	Field and Description
protected ObjectIdentifier	AlterTableOperation.tableIdentifier

Methods in org.apache.flink.table.operations.ddl that return ObjectIdentifier

Modifier and Type	Method and Description
ObjectIdentifier	DropFunctionOperation.getFunctionIdentifier()
ObjectIdentifier	CreateFunctionOperation.getFunctionIdentifier()
ObjectIdentifier	AlterFunctionOperation.getFunctionIdentifier()
ObjectIdentifier	AlterTableRenameOperation.getNewTableIdentifier()
ObjectIdentifier	CreateTableOperation.getTableIdentifier()
ObjectIdentifier	AlterTableOperation.getTableIdentifier()
ObjectIdentifier	DropTableOperation.getTableIdentifier()

Constructors in org.apache.flink.table.operations.ddl with parameters of type ObjectIdentifier

Constructor and Description
AlterFunctionOperation(ObjectIdentifier functionIdentifier, CatalogFunction catalogFunction, boolean ifExists, boolean isTemporary)
AlterTableOperation(ObjectIdentifier tableIdentifier)
AlterTablePropertiesOperation(ObjectIdentifier tableIdentifier, CatalogTable catalogTable)
AlterTableRenameOperation(ObjectIdentifier tableIdentifier, ObjectIdentifier newTableIdentifier)
CreateFunctionOperation(ObjectIdentifier functionIdentifier, CatalogFunction catalogFunction, boolean ignoreIfExists, boolean isTemporary)
CreateTableOperation(ObjectIdentifier tableIdentifier, CatalogTable catalogTable, boolean ignoreIfExists)
DropFunctionOperation(ObjectIdentifier functionIdentifier, boolean ifExists, boolean isTemporary)
DropTableOperation(ObjectIdentifier tableIdentifier, boolean ifExists)

Uses of ObjectIdentifier in org.apache.flink.table.planner.catalog

Methods in org.apache.flink.table.planner.catalog that return ObjectIdentifier

Modifier and Type	Method and Description
ObjectIdentifier	CatalogSchemaTable.getTableIdentifier()

Constructors in org.apache.flink.table.planner.catalog with parameters of type ObjectIdentifier

Constructor and Description
CatalogSchemaTable(ObjectIdentifier tableIdentifier, CatalogBaseTable catalogBaseTable, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic, TableFactory tableFactory, boolean isStreaming, boolean isTemporary) Create a CatalogSchemaTable instance.

Uses of ObjectIdentifier in org.apache.flink.table.planner.operations

Methods in org.apache.flink.table.planner.operations that return ObjectIdentifier

Modifier and Type	Method and Description
ObjectIdentifier	DataStreamQueryOperation.getIdentifier()
ObjectIdentifier	RichTableSourceQueryOperation.getIdentifier()

Constructors in org.apache.flink.table.planner.operations with parameters of type ObjectIdentifier

Constructor and Description
DataStreamQueryOperation(ObjectIdentifier identifier, DataStream<E> dataStream, int[] fieldIndices, TableSchema tableSchema, boolean[] fieldNullables, boolean producesUpdates, boolean isAccRetract, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)
RichTableSourceQueryOperation(ObjectIdentifier identifier, TableSource<T> tableSource, org.apache.flink.table.planner.plan.stats.FlinkStatistic statistic)

Uses of ObjectIdentifier in org.apache.flink.table.types.logical

Methods in org.apache.flink.table.types.logical that return ObjectIdentifier

Modifier and Type	Method and Description
ObjectIdentifier	DistinctType.getObjectIdentifier()

Methods in org.apache.flink.table.types.logical that return types with arguments of type ObjectIdentifier

Modifier and Type	Method and Description
Optional<ObjectIdentifier>	UserDefinedType.getOptionalObjectIdentifier()

Methods in org.apache.flink.table.types.logical with parameters of type ObjectIdentifier

Modifier and Type	Method and Description
static StructuredType.Builder	StructuredType.newBuilder(ObjectIdentifier objectIdentifier) Creates a builder for a StructuredType that has been stored in a catalog and is identified by an ObjectIdentifier.
static StructuredType.Builder	StructuredType.newBuilder(ObjectIdentifier objectIdentifier, Class<?> implementationClass) Creates a builder for a StructuredType that has been stored in a catalog and is identified by an ObjectIdentifier.
static DistinctType.Builder	DistinctType.newBuilder(ObjectIdentifier objectIdentifier, LogicalType sourceType) Creates a builder for a DistinctType.

Constructors in org.apache.flink.table.types.logical with parameters of type ObjectIdentifier

Constructor and Description
Builder(ObjectIdentifier objectIdentifier)
Builder(ObjectIdentifier objectIdentifier, Class<?> implementationClass)
Builder(ObjectIdentifier objectIdentifier, LogicalType sourceType)