Package | Description |
---|---|
org.apache.flink.fnexecution.v1 | |
org.apache.flink.streaming.api.utils |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.Builder.build() |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.Builder.buildPartial() |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfoOrBuilder.getCollectionElementType()
.org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.getCollectionElementType()
.org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.Builder.getCollectionElementType()
.org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2; |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.getDefaultInstance() |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.getDefaultInstanceForType() |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.Builder.getDefaultInstanceForType() |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.RowTypeInfo.FieldOrBuilder.getFieldType()
.org.apache.flink.fn_execution.v1.TypeInfo field_type = 2; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.RowTypeInfo.Field.getFieldType()
.org.apache.flink.fn_execution.v1.TypeInfo field_type = 2; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder.getFieldType()
.org.apache.flink.fn_execution.v1.TypeInfo field_type = 2; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.TupleTypeInfoOrBuilder.getFieldTypes(int index)
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.TupleTypeInfo.getFieldTypes(int index)
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder.getFieldTypes(int index)
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.MapTypeInfoOrBuilder.getKeyType()
.org.apache.flink.fn_execution.v1.TypeInfo key_type = 1; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.MapTypeInfo.getKeyType()
.org.apache.flink.fn_execution.v1.TypeInfo key_type = 1; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder.getKeyType()
.org.apache.flink.fn_execution.v1.TypeInfo key_type = 1; |
FlinkFnApi.TypeInfo |
FlinkFnApi.UserDefinedDataStreamFunctionOrBuilder.getKeyTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5; |
FlinkFnApi.TypeInfo |
FlinkFnApi.UserDefinedDataStreamFunction.getKeyTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5; |
FlinkFnApi.TypeInfo |
FlinkFnApi.UserDefinedDataStreamFunction.Builder.getKeyTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5; |
FlinkFnApi.TypeInfo |
FlinkFnApi.CoderInfoDescriptor.RawTypeOrBuilder.getTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo type_info = 1; |
FlinkFnApi.TypeInfo |
FlinkFnApi.CoderInfoDescriptor.RawType.getTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo type_info = 1; |
FlinkFnApi.TypeInfo |
FlinkFnApi.CoderInfoDescriptor.RawType.Builder.getTypeInfo()
.org.apache.flink.fn_execution.v1.TypeInfo type_info = 1; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.MapTypeInfoOrBuilder.getValueType()
.org.apache.flink.fn_execution.v1.TypeInfo value_type = 2; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.MapTypeInfo.getValueType()
.org.apache.flink.fn_execution.v1.TypeInfo value_type = 2; |
FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder.getValueType()
.org.apache.flink.fn_execution.v1.TypeInfo value_type = 2; |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseDelimitedFrom(InputStream input) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseFrom(byte[] data) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseFrom(ByteBuffer data) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseFrom(com.google.protobuf.ByteString data) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseFrom(com.google.protobuf.CodedInputStream input) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseFrom(InputStream input) |
static FlinkFnApi.TypeInfo |
FlinkFnApi.TypeInfo.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<FlinkFnApi.TypeInfo> |
FlinkFnApi.TypeInfo.TupleTypeInfoOrBuilder.getFieldTypesList()
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1; |
List<FlinkFnApi.TypeInfo> |
FlinkFnApi.TypeInfo.TupleTypeInfo.getFieldTypesList()
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1; |
List<FlinkFnApi.TypeInfo> |
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder.getFieldTypesList()
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1; |
com.google.protobuf.Parser<FlinkFnApi.TypeInfo> |
FlinkFnApi.TypeInfo.getParserForType() |
static com.google.protobuf.Parser<FlinkFnApi.TypeInfo> |
FlinkFnApi.TypeInfo.parser() |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder |
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder.addFieldTypes(FlinkFnApi.TypeInfo value)
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1; |
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder |
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder.addFieldTypes(int index,
FlinkFnApi.TypeInfo value)
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1; |
FlinkFnApi.TypeInfo.Builder |
FlinkFnApi.TypeInfo.Builder.mergeCollectionElementType(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2; |
FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder |
FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder.mergeFieldType(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo field_type = 2; |
FlinkFnApi.TypeInfo.Builder |
FlinkFnApi.TypeInfo.Builder.mergeFrom(FlinkFnApi.TypeInfo other) |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder.mergeKeyType(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo key_type = 1; |
FlinkFnApi.UserDefinedDataStreamFunction.Builder |
FlinkFnApi.UserDefinedDataStreamFunction.Builder.mergeKeyTypeInfo(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5; |
FlinkFnApi.CoderInfoDescriptor.RawType.Builder |
FlinkFnApi.CoderInfoDescriptor.RawType.Builder.mergeTypeInfo(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo type_info = 1; |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder.mergeValueType(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo value_type = 2; |
static FlinkFnApi.TypeInfo.Builder |
FlinkFnApi.TypeInfo.newBuilder(FlinkFnApi.TypeInfo prototype) |
FlinkFnApi.TypeInfo.Builder |
FlinkFnApi.TypeInfo.Builder.setCollectionElementType(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo collection_element_type = 2; |
FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder |
FlinkFnApi.TypeInfo.RowTypeInfo.Field.Builder.setFieldType(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo field_type = 2; |
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder |
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder.setFieldTypes(int index,
FlinkFnApi.TypeInfo value)
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1; |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder.setKeyType(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo key_type = 1; |
FlinkFnApi.UserDefinedDataStreamFunction.Builder |
FlinkFnApi.UserDefinedDataStreamFunction.Builder.setKeyTypeInfo(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo key_type_info = 5; |
FlinkFnApi.CoderInfoDescriptor.RawType.Builder |
FlinkFnApi.CoderInfoDescriptor.RawType.Builder.setTypeInfo(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo type_info = 1; |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder |
FlinkFnApi.TypeInfo.MapTypeInfo.Builder.setValueType(FlinkFnApi.TypeInfo value)
.org.apache.flink.fn_execution.v1.TypeInfo value_type = 2; |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder |
FlinkFnApi.TypeInfo.TupleTypeInfo.Builder.addAllFieldTypes(Iterable<? extends FlinkFnApi.TypeInfo> values)
repeated .org.apache.flink.fn_execution.v1.TypeInfo field_types = 1; |
Modifier and Type | Method and Description |
---|---|
static FlinkFnApi.TypeInfo |
PythonTypeUtils.TypeInfoToProtoConverter.toTypeInfoProto(TypeInformation<?> typeInformation,
ClassLoader userClassLoader)
userClassLoader could be null if no external class loading is needed, e.g.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.