Client API

FlinkTasksClientFactory()

Factory for creating memoized FlinkTasksClients

FlinkTasksClient(kafka_broker_url, ...[, ...])

Client for submitting TaskRequests / TaskActionRequests

TaskStatus(value)

An enumeration.