Package | Description |
---|---|
org.apache.flink.formats.protobuf | |
org.apache.flink.formats.protobuf.deserialize | |
org.apache.flink.formats.protobuf.serialize |
Modifier and Type | Method and Description |
---|---|
PbFormatConfig |
PbFormatConfig.PbFormatConfigBuilder.build() |
PbFormatConfig |
PbFormatContext.getPbFormatConfig() |
Constructor and Description |
---|
PbDecodingFormat(PbFormatConfig formatConfig) |
PbEncodingFormat(PbFormatConfig pbFormatConfig) |
PbFormatContext(String outerPrefix,
PbFormatConfig pbFormatConfig) |
Constructor and Description |
---|
PbRowDataDeserializationSchema(RowType rowType,
TypeInformation<RowData> resultTypeInfo,
PbFormatConfig formatConfig) |
ProtoToRowConverter(RowType rowType,
PbFormatConfig formatConfig) |
Constructor and Description |
---|
PbRowDataSerializationSchema(RowType rowType,
PbFormatConfig pbFormatConfig) |
RowToProtoConverter(RowType rowType,
PbFormatConfig formatConfig) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.