Class Hierarchy
- java.lang.Object
- org.apache.flink.connector.base.table.sink.AsyncDynamicTableSink<RequestEntryT> (implements org.apache.flink.table.connector.sink.DynamicTableSink)
- s2.flink.table.upsert.S2UpsertDynamicTableSink
- org.apache.flink.connector.base.table.sink.AsyncDynamicTableSinkBuilder<RequestEntryT,ConcreteBuilderT>
- s2.flink.table.upsert.S2UpsertDynamicTableSink.S2UpsertDynamicTableSinkBuilder
- org.apache.flink.connector.base.table.AsyncDynamicTableSinkFactory (implements org.apache.flink.table.factories.DynamicTableSinkFactory)
- s2.flink.table.upsert.S2UpsertDynamicTableFactory (implements org.apache.flink.table.factories.DynamicTableSourceFactory)
- s2.flink.table.upsert.S2UpsertDynamicTableSource (implements org.apache.flink.table.connector.source.ScanTableSource)
- s2.flink.table.upsert.S2UpsertDynamicTableSource.S2UpsertDynamicTableSourceBuilder
- s2.flink.table.upsert.UpsertRowDataDeserializer (implements s2.flink.source.serialization.S2ContextDeserializationSchema<T>)
- org.apache.flink.connector.base.table.sink.AsyncDynamicTableSink<RequestEntryT> (implements org.apache.flink.table.connector.sink.DynamicTableSink)