Package io.github.flink.gcp.connector.base.rpc


package io.github.flink.gcp.connector.base.rpc
  • Classes
    Class
    Description
    Transport channel providers pointing a gRPC client at an emulator.
    The host:port of a Google Cloud emulator, parsed and validated on the client rather than on a TaskManager after the job has been submitted (issue #235).
    Extraction of gRPC status codes from the exceptions the Google Cloud clients surface.