org.apache.beam.sdk.io.iceberg

Interface DynamicDestinations

All Superinterfaces:

java.io.Serializable

public interface DynamicDestinations
extends java.io.Serializable

Method Summary

Modifier and Type	Method and Description
Row	assignDestinationMetadata(Row data)
Schema	getMetadataSchema()
IcebergDestination	instantiateDestination(Row dest)
static DynamicDestinations	singleTable(org.apache.iceberg.catalog.TableIdentifier tableId)

Method Detail

getMetadataSchema

Schema getMetadataSchema()

assignDestinationMetadata

Row assignDestinationMetadata(Row data)

instantiateDestination

IcebergDestination instantiateDestination(Row dest)

singleTable

static DynamicDestinations singleTable(org.apache.iceberg.catalog.TableIdentifier tableId)