1 réponse
- Le plus récent
- Le plus de votes
- La plupart des commentaires
0
If you are using %flink.pyflink or %flink as your interpreters, you will need to use the ZeppelinContext to visualize the results within the notebook.
%flink // create a DataStream val dataStream = senv.fromElements("Alice", "Bob", "John") // interpret the insert-only DataStream as a Table val inputTable = stenv.fromDataStream(dataStream) z.show(inputTable, streamType="update")
For more PyFlink specific examples, see Query your data streams interactively using Kinesis Data Analytics Studio and Python.
répondu il y a un an
Contenus pertinents
- demandé il y a un an
- demandé il y a 6 mois
- demandé il y a 2 mois
- demandé il y a un an
- AWS OFFICIELA mis à jour il y a 6 mois
- AWS OFFICIELA mis à jour il y a 2 ans