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	getData(Row element)
Schema	getDataSchema()
java.lang.String	getTableStringIdentifier(ValueInSingleWindow<Row> element)
IcebergDestination	instantiateDestination(java.lang.String destination)
static DynamicDestinations	singleTable(org.apache.iceberg.catalog.TableIdentifier tableId, Schema inputSchema)

Method Detail

getDataSchema

Schema getDataSchema()

getData

Row getData(Row element)

instantiateDestination

IcebergDestination instantiateDestination(java.lang.String destination)

getTableStringIdentifier

java.lang.String getTableStringIdentifier(ValueInSingleWindow<Row> element)

singleTable

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