Package org.apache.beam.sdk.io.iceberg

Interface DynamicDestinations

All Superinterfaces:

Serializable

public interface DynamicDestinations
extends Serializable

Method Summary

Modifier and Type	Method	Description
Row	getData(Row element)
Schema	getDataSchema()
String	getTableStringIdentifier(ValueInSingleWindow<Row> element)
IcebergDestination	instantiateDestination(String destination)
static DynamicDestinations	singleTable(org.apache.iceberg.catalog.TableIdentifier tableId, Schema inputSchema)

Method Details

getDataSchema

Schema getDataSchema()

getData

Row getData(Row element)

instantiateDestination

IcebergDestination instantiateDestination(String destination)

getTableStringIdentifier

String getTableStringIdentifier(ValueInSingleWindow<Row> element)

singleTable

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