Class PythonCallable
- java.lang.Object
-
- org.apache.beam.sdk.schemas.logicaltypes.PythonCallable
-
- All Implemented Interfaces:
java.io.Serializable
,Schema.LogicalType<PythonCallableSource,java.lang.String>
@Experimental(SCHEMAS) public class PythonCallable extends java.lang.Object implements Schema.LogicalType<PythonCallableSource,java.lang.String>
A logical type for PythonCallableSource objects.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
IDENTIFIER
-
Constructor Summary
Constructors Constructor Description PythonCallable()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description @Nullable Schema.FieldType
getArgumentType()
A schema type representing how to interpret the argument.Schema.FieldType
getBaseType()
The baseSchema.FieldType
used to store values of this type.java.lang.String
getIdentifier()
The unique identifier for this type.@NonNull java.lang.String
toBaseType(@NonNull PythonCallableSource input)
Convert the input type to the type Java type used by the baseSchema.FieldType
.@NonNull PythonCallableSource
toInputType(@NonNull java.lang.String base)
Convert the Java type used by the baseSchema.FieldType
to the input type.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.beam.sdk.schemas.Schema.LogicalType
getArgument
-
-
-
-
Method Detail
-
getIdentifier
public java.lang.String getIdentifier()
Description copied from interface:Schema.LogicalType
The unique identifier for this type.- Specified by:
getIdentifier
in interfaceSchema.LogicalType<PythonCallableSource,java.lang.String>
-
getArgumentType
public @Nullable Schema.FieldType getArgumentType()
Description copied from interface:Schema.LogicalType
A schema type representing how to interpret the argument.null
indicates this logical type is not parameterized by an argument.- Specified by:
getArgumentType
in interfaceSchema.LogicalType<PythonCallableSource,java.lang.String>
-
getBaseType
public Schema.FieldType getBaseType()
Description copied from interface:Schema.LogicalType
The baseSchema.FieldType
used to store values of this type.- Specified by:
getBaseType
in interfaceSchema.LogicalType<PythonCallableSource,java.lang.String>
-
toBaseType
public @NonNull java.lang.String toBaseType(@NonNull PythonCallableSource input)
Description copied from interface:Schema.LogicalType
Convert the input type to the type Java type used by the baseSchema.FieldType
.- Specified by:
toBaseType
in interfaceSchema.LogicalType<PythonCallableSource,java.lang.String>
-
toInputType
public @NonNull PythonCallableSource toInputType(@NonNull java.lang.String base)
Description copied from interface:Schema.LogicalType
Convert the Java type used by the baseSchema.FieldType
to the input type.- Specified by:
toInputType
in interfaceSchema.LogicalType<PythonCallableSource,java.lang.String>
-
-