flink_rest_client package

Subpackages

• flink_rest_client.v1 package
  • Submodules
  • flink_rest_client.v1.client module
  • flink_rest_client.v1.jars module
  • flink_rest_client.v1.jobmanager module
  • flink_rest_client.v1.jobs module
  • flink_rest_client.v1.taskmanagers module
  • Module contents

Submodules

flink_rest_client.client module

class flink_rest_client.client.FlinkRestClient

Bases: object

static get(host, port=None, version=None)

Constructs a new rest client instance.

Parameters

• host (str) – Hostname of Flink Jobmanager

• port (int) – Port number. Default value: 8081

• version (str) – Version of the REST API. Default value: v1

• version –

flink_rest_client.common module

exception flink_rest_client.common.RestException(*args: object)

Bases: Exception

Exception to catch REST API related exceptions.

Module contents