Class GettingStartedExample
- java.lang.Object
-
- org.apache.flink.table.examples.java.basics.GettingStartedExample
-
public final class GettingStartedExample extends Object
Example for getting started with the Table & SQL API.The example shows how to create, transform, and query a table. It should give a first impression about the look-and-feel of the API without going too much into details. See the other examples for using connectors or more complex operations.
In particular, the example shows how to
- setup a
TableEnvironment
, - use the environment for creating example tables, registering views, and executing SQL queries,
- transform tables with filters and projections,
- declare user-defined functions,
- and print/collect results locally.
The example executes two Flink jobs. The results are written to stdout.
- setup a
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
GettingStartedExample.AddressNormalizer
We can put frequently used procedures in user-defined functions.
-
Constructor Summary
Constructors Constructor Description GettingStartedExample()
-