DataStream API interoperability

The Table API supports seamless integration with the DataStream API by exposing methods that convert DataStreams to Tables, and Tables back to DataStreams.

These integration points are used to run SQL queries on your DataStreams, and convert the results back into other streams, or insert them into one of the supported table sinks. This provides new ways to build your streaming application logic.

The followings are the supported DataStream type conversions:
  • DataStream<Row>
  • DataStream<TupleX<...>>