public class PythonCallable extends java.lang.Object implements Schema.LogicalType<org.apache.beam.sdk.util.PythonCallableSource,java.lang.String>
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
IDENTIFIER |
Constructor and Description |
---|
PythonCallable() |
Modifier and Type | Method and Description |
---|---|
Schema.FieldType |
getArgumentType()
A schema type representing how to interpret the argument.
|
Schema.FieldType |
getBaseType()
The base
Schema.FieldType used to store values of this type. |
java.lang.String |
getIdentifier()
The unique identifier for this type.
|
@NonNull java.lang.String |
toBaseType(@NonNull org.apache.beam.sdk.util.PythonCallableSource input)
Convert the input type to the type Java type used by the base
Schema.FieldType . |
@NonNull org.apache.beam.sdk.util.PythonCallableSource |
toInputType(@NonNull java.lang.String base)
Convert the Java type used by the base
Schema.FieldType to the input type. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getArgument
public java.lang.String getIdentifier()
Schema.LogicalType
getIdentifier
in interface Schema.LogicalType<org.apache.beam.sdk.util.PythonCallableSource,java.lang.String>
public Schema.FieldType getArgumentType()
Schema.LogicalType
null
indicates this logical
type is not parameterized by an argument.getArgumentType
in interface Schema.LogicalType<org.apache.beam.sdk.util.PythonCallableSource,java.lang.String>
public Schema.FieldType getBaseType()
Schema.LogicalType
Schema.FieldType
used to store values of this type.getBaseType
in interface Schema.LogicalType<org.apache.beam.sdk.util.PythonCallableSource,java.lang.String>
public @NonNull java.lang.String toBaseType(@NonNull org.apache.beam.sdk.util.PythonCallableSource input)
Schema.LogicalType
Schema.FieldType
.toBaseType
in interface Schema.LogicalType<org.apache.beam.sdk.util.PythonCallableSource,java.lang.String>
public @NonNull org.apache.beam.sdk.util.PythonCallableSource toInputType(@NonNull java.lang.String base)
Schema.LogicalType
Schema.FieldType
to the input type.toInputType
in interface Schema.LogicalType<org.apache.beam.sdk.util.PythonCallableSource,java.lang.String>