Add metrics to count different kinds of records

1. Add metrics to count different kinds of records
2. Add more UDF examples

Support output rate limiting

This release adds the support for rate limiting. Also, users may choose to discard all input data for debugging purposes.

Support all changelog mode and output type formatting

0.3.4

Support all changelog mode and external type formatting

Universal Logger Sink Implementation

Support both Flink 1.11 and 1.13

Added ENHANCED_SPLIT_INDEX Function

Provide ENHANCED_SPLIT_INDEX function to support multiple consecutive separators.

Logger Sink with Optional Prefix

Support custom prefix (print-identifier)

Added Logger Table Sink

Users could use this table sink for debugging purposes.

UDF Examples

Added EncodeLatin1 & DecodeLatin1 UDF Examples

WordCount

WordCount 程序包