Bulk Operation

FLINK-8971 Assign uids to all operators

FLINK-8971 Add exception throwing map function that simulates failures to the general purpose DataStream job

FLINK-8971 Add operators with input type that goes through custom, stateful serialization

FLINK-8971 Add operators with input type that goes through Avro serialization (with schema/generic)

FLINK-8971 Add operators with input type that goes through Kryo serialization (registered/generic/custom)

FLINK-8971 Ensure the job has an operator with operator state.

FLINK-8971 Add user-defined watermark assigner and timestamp extractor to the test job

FLINK-8971 Add sliding window aggregation to the job

FLINK-8971 Include an operator with broadcast and union state

FLINK-8971 Add a test operator with keyed state that uses custom, stateful serializer

FLINK-8971 Add a test operator with keyed state that uses Avro serializer (from schema/by reflection)

FLINK-8971 Add a test operator with keyed state that uses Kryo serializer (registered/unregistered/custom)

FLINK-8971 Implement source and operator that validate exactly-once