Package org.apache.flink.table.examples.java.basics
-
Class Summary Class Description GettingStartedExample Example for getting started with the Table & SQL API.GettingStartedExample.AddressNormalizer We can put frequently used procedures in user-defined functions.StreamSQLExample Simple example for demonstrating the use of SQL on a table backed by aDataStream
in Java DataStream API.StreamSQLExample.Order Simple POJO.StreamWindowSQLExample Simple example for demonstrating the use of SQL in Java.TemporalJoinSQLExample Example for demonstrating the use of temporal join between a table backed by aDataStream
and a table backed by a change log stream.TemporalJoinSQLExample.EnrichedTransaction Enriched transaction by joining with the currency rate table.TemporalJoinSQLExample.Transaction A simple class to represent a transaction.UpdatingTopCityExample Example for aggregating and ranking data using Flink SQL on updating tables.WordCountSQLExample The famous word count example that shows a minimal Flink SQL job in batch execution mode.