Zander Matheson created FLINK-38389:
---------------------------------------

             Summary: Add .show(), .head() and .tail() method to PyFlink Table 
API
                 Key: FLINK-38389
                 URL: https://issues.apache.org/jira/browse/FLINK-38389
             Project: Flink
          Issue Type: New Feature
          Components: Table SQL / API
            Reporter: Zander Matheson


Problem Statement:

Today PyFlink has a number of small differences to other dataframe/table type 
libraries. One of those is that there is no method to show the data easily. 
This is possible in both lazily and non-lazily computed libraries and therefore 
should be possible to do in Flink.

To make the Table API feel more friendly to Python developers, we should add 
some helper functions for data exploration like those that exist in pandas, 
pyspark and other dataframe libraries. 

The first of these we could possibly add are show(), head() and tail(). Tail, 
might not be so trivial, because we can't override the connector to read from a 
certain point.

Show will show a snippet of data up to a number of rows as specified. 

All the methods will simply return the data as a pandas dataframe to take 
advantage of the print and display capabilities inherent to it. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to