Constructor and Description |
---|
ExecutableOperationUtils() |
Modifier and Type | Method and Description |
---|---|
static DynamicTableSink |
createDynamicTableSink(Catalog catalog,
java.util.function.Supplier<Optional<DynamicTableSinkFactory>> sinkFactorySupplier,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
Map<String,String> enrichmentOptions,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSink from a CatalogTable . |
public static DynamicTableSink createDynamicTableSink(@Nullable Catalog catalog, java.util.function.Supplier<Optional<DynamicTableSinkFactory>> sinkFactorySupplier, ObjectIdentifier objectIdentifier, ResolvedCatalogTable catalogTable, Map<String,String> enrichmentOptions, ReadableConfig configuration, ClassLoader classLoader, boolean isTemporary)
DynamicTableSink
from a CatalogTable
.
It'll try to create table sink from to , then try to create from passed secondly. Otherwise, an attempt is made to discover a matching
factory using Java SPI (see Factory
for details).
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.