Worker API

FlinkTasks([default_namespace, ...])	Flink Tasks implementation
TaskContext(context, egress_type_name[, ...])	Task context wrapper around Flink context
PipelineBuilder([pipeline])	Builder class for creating pipelines
DefaultSerialiser([known_proto_types, ...])	Default protobuf serialiser for Flink Tasks
EventHandlers()