@Deprecated @Internal public class TableSinkFactoryContextImpl extends Object implements TableSinkFactory.Context
TableSinkFactory.Context
.Constructor and Description |
---|
TableSinkFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config,
boolean isBounded,
boolean isTemporary)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
getConfiguration()
Deprecated.
|
ObjectIdentifier |
getObjectIdentifier()
Deprecated.
|
CatalogTable |
getTable()
Deprecated.
|
boolean |
isBounded()
Deprecated.
It depends on whether the
TableEnvironment execution mode is batch. |
boolean |
isTemporary()
Deprecated.
Whether the table is temporary.
|
public TableSinkFactoryContextImpl(ObjectIdentifier identifier, CatalogTable table, ReadableConfig config, boolean isBounded, boolean isTemporary)
public ObjectIdentifier getObjectIdentifier()
getObjectIdentifier
in interface TableSinkFactory.Context
CatalogTable
.public CatalogTable getTable()
getTable
in interface TableSinkFactory.Context
CatalogTable
instance.public ReadableConfig getConfiguration()
getConfiguration
in interface TableSinkFactory.Context
TableConfig#getConfiguration()
which holds the current TableEnvironment
session configurations.public boolean isBounded()
TableSinkFactory.Context
TableEnvironment
execution mode is batch.
In the future, the new sink interface will infer from input to source. See Source.getBoundedness()
.
isBounded
in interface TableSinkFactory.Context
public boolean isTemporary()
TableSinkFactory.Context
isTemporary
in interface TableSinkFactory.Context
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.