public class External
extends java.lang.Object
External
provides a cross-language transform via expansion services in foreign SDKs.
In order to use External
transform, a user should know 1) URN of the target transform 2)
bytes encoding schema for configuration parameters 3) connection endpoint of the expansion
service. Note that this is a low-level API and mainly for internal use. A user may want to use
high-level wrapper classes rather than this one.
Modifier and Type | Class and Description |
---|---|
static class |
External.ExpandableTransform<InputT extends PInput,OutputT extends POutput>
Base Expandable Transform which calls ExpansionService to expand itself.
|
static class |
External.MultiOutputExpandableTransform<InputT extends PInput>
Expandable transform for output type of PCollectionTuple.
|
static class |
External.SingleOutputExpandableTransform<InputT extends PInput,OutputT>
Expandable transform for output type of PCollection.
|
Constructor and Description |
---|
External() |
Modifier and Type | Method and Description |
---|---|
static <InputT extends PInput,OutputT> |
of(java.lang.String urn,
byte[] payload,
java.lang.String endpoint) |
static <InputT extends PInput,OutputT> |
of(java.lang.String urn,
byte[] payload,
java.lang.String endpoint,
ExpansionServiceClientFactory clientFactory) |
public static <InputT extends PInput,OutputT> External.SingleOutputExpandableTransform<InputT,OutputT> of(java.lang.String urn, byte[] payload, java.lang.String endpoint)
public static <InputT extends PInput,OutputT> External.SingleOutputExpandableTransform<InputT,OutputT> of(java.lang.String urn, byte[] payload, java.lang.String endpoint, ExpansionServiceClientFactory clientFactory)