DynamicDestinations (Apache Beam 2.67.0)

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)