Package | Description |
---|---|
org.apache.flink.fnexecution.v1 | |
org.apache.flink.table.runtime.typeutils |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.Builder.build() |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.Builder.buildPartial() |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldTypeOrBuilder.getCollectionElementType()
.org.apache.flink.fn_execution.v1.Schema.FieldType collection_element_type = 3; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.getCollectionElementType()
.org.apache.flink.fn_execution.v1.Schema.FieldType collection_element_type = 3; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.Builder.getCollectionElementType()
.org.apache.flink.fn_execution.v1.Schema.FieldType collection_element_type = 3; |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.getDefaultInstance() |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.getDefaultInstanceForType() |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.Builder.getDefaultInstanceForType() |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListViewOrBuilder.getElementType()
.org.apache.flink.fn_execution.v1.Schema.FieldType element_type = 1; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView.getElementType()
.org.apache.flink.fn_execution.v1.Schema.FieldType element_type = 1; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView.Builder.getElementType()
.org.apache.flink.fn_execution.v1.Schema.FieldType element_type = 1; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapViewOrBuilder.getKeyType()
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 1; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.getKeyType()
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 1; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder.getKeyType()
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 1; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunctionsOrBuilder.getKeyType()
The schema of the grouping keys.
|
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunctions.getKeyType()
The schema of the grouping keys.
|
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.getKeyType()
The schema of the grouping keys.
|
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.MapInfoOrBuilder.getKeyType()
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 1; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.MapInfo.getKeyType()
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 1; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.MapInfo.Builder.getKeyType()
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 1; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldOrBuilder.getType()
.org.apache.flink.fn_execution.v1.Schema.FieldType type = 3; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.Field.getType()
.org.apache.flink.fn_execution.v1.Schema.FieldType type = 3; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.Field.Builder.getType()
.org.apache.flink.fn_execution.v1.Schema.FieldType type = 3; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapViewOrBuilder.getValueType()
.org.apache.flink.fn_execution.v1.Schema.FieldType value_type = 2; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.getValueType()
.org.apache.flink.fn_execution.v1.Schema.FieldType value_type = 2; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder.getValueType()
.org.apache.flink.fn_execution.v1.Schema.FieldType value_type = 2; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.MapInfoOrBuilder.getValueType()
.org.apache.flink.fn_execution.v1.Schema.FieldType value_type = 2; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.MapInfo.getValueType()
.org.apache.flink.fn_execution.v1.Schema.FieldType value_type = 2; |
FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.MapInfo.Builder.getValueType()
.org.apache.flink.fn_execution.v1.Schema.FieldType value_type = 2; |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseDelimitedFrom(InputStream input) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseFrom(byte[] data) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseFrom(ByteBuffer data) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseFrom(com.google.protobuf.ByteString data) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseFrom(com.google.protobuf.CodedInputStream input) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseFrom(InputStream input) |
static FlinkFnApi.Schema.FieldType |
FlinkFnApi.Schema.FieldType.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<FlinkFnApi.Schema.FieldType> |
FlinkFnApi.Schema.FieldType.getParserForType() |
static com.google.protobuf.Parser<FlinkFnApi.Schema.FieldType> |
FlinkFnApi.Schema.FieldType.parser() |
Modifier and Type | Method and Description |
---|---|
FlinkFnApi.Schema.FieldType.Builder |
FlinkFnApi.Schema.FieldType.Builder.mergeCollectionElementType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType collection_element_type = 3; |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView.Builder |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView.Builder.mergeElementType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType element_type = 1; |
FlinkFnApi.Schema.FieldType.Builder |
FlinkFnApi.Schema.FieldType.Builder.mergeFrom(FlinkFnApi.Schema.FieldType other) |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder.mergeKeyType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.mergeKeyType(FlinkFnApi.Schema.FieldType value)
The schema of the grouping keys.
|
FlinkFnApi.Schema.MapInfo.Builder |
FlinkFnApi.Schema.MapInfo.Builder.mergeKeyType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 1; |
FlinkFnApi.Schema.Field.Builder |
FlinkFnApi.Schema.Field.Builder.mergeType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType type = 3; |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder.mergeValueType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType value_type = 2; |
FlinkFnApi.Schema.MapInfo.Builder |
FlinkFnApi.Schema.MapInfo.Builder.mergeValueType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType value_type = 2; |
static FlinkFnApi.Schema.FieldType.Builder |
FlinkFnApi.Schema.FieldType.newBuilder(FlinkFnApi.Schema.FieldType prototype) |
FlinkFnApi.Schema.FieldType.Builder |
FlinkFnApi.Schema.FieldType.Builder.setCollectionElementType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType collection_element_type = 3; |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView.Builder |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.ListView.Builder.setElementType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType element_type = 1; |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder.setKeyType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 1; |
FlinkFnApi.UserDefinedAggregateFunctions.Builder |
FlinkFnApi.UserDefinedAggregateFunctions.Builder.setKeyType(FlinkFnApi.Schema.FieldType value)
The schema of the grouping keys.
|
FlinkFnApi.Schema.MapInfo.Builder |
FlinkFnApi.Schema.MapInfo.Builder.setKeyType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType key_type = 1; |
FlinkFnApi.Schema.Field.Builder |
FlinkFnApi.Schema.Field.Builder.setType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType type = 3; |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder |
FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.MapView.Builder.setValueType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType value_type = 2; |
FlinkFnApi.Schema.MapInfo.Builder |
FlinkFnApi.Schema.MapInfo.Builder.setValueType(FlinkFnApi.Schema.FieldType value)
.org.apache.flink.fn_execution.v1.Schema.FieldType value_type = 2; |
Modifier and Type | Method and Description |
---|---|
protected FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.defaultMethod(LogicalType logicalType) |
static FlinkFnApi.Schema.FieldType |
PythonTypeUtils.toProtoType(LogicalType logicalType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(ArrayType arrayType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(BigIntType bigIntType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(BinaryType binaryType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(BooleanType booleanType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(CharType charType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(DateType dateType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(DecimalType decimalType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(DoubleType doubleType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(FloatType floatType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(IntType intType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(LocalZonedTimestampType localZonedTimestampType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(MapType mapType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(RowType rowType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(SmallIntType smallIntType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(TimestampType timestampType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(TimeType timeType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(TinyIntType tinyIntType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(VarBinaryType varBinaryType) |
FlinkFnApi.Schema.FieldType |
PythonTypeUtils.LogicalTypeToProtoTypeConverter.visit(VarCharType varCharType) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.