@Internal public class TableSinkFactoryContextImpl extends Object implements TableSinkFactory.Context
TableSinkFactory.Context
.Constructor and Description |
---|
TableSinkFactoryContextImpl(ObjectIdentifier identifier,
CatalogTable table,
ReadableConfig config,
boolean isBounded) |
Modifier and Type | Method and Description |
---|---|
ReadableConfig |
getConfiguration() |
ObjectIdentifier |
getObjectIdentifier() |
CatalogTable |
getTable() |
boolean |
isBounded()
It depends on whether the
TableEnvironment execution mode is batch. |
public TableSinkFactoryContextImpl(ObjectIdentifier identifier, CatalogTable table, ReadableConfig config, boolean isBounded)
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
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.