Package io.github.flink.gcp.connector.base.rpc
package io.github.flink.gcp.connector.base.rpc
-
ClassesClassDescriptionTransport channel providers pointing a gRPC client at an emulator.The
host:portof 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.