Package | Description |
---|---|
org.apache.flink.streaming.tests.avro |
Modifier and Type | Method and Description |
---|---|
ComplexPayloadAvro |
ComplexPayloadAvro.Builder.build() |
static ComplexPayloadAvro |
ComplexPayloadAvro.fromByteBuffer(ByteBuffer b)
Deserializes a ComplexPayloadAvro from a ByteBuffer.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.avro.message.BinaryMessageDecoder<ComplexPayloadAvro> |
ComplexPayloadAvro.createDecoder(org.apache.avro.message.SchemaStore resolver)
Create a new BinaryMessageDecoder instance for this class that uses the specified
SchemaStore . |
static org.apache.avro.message.BinaryMessageDecoder<ComplexPayloadAvro> |
ComplexPayloadAvro.getDecoder()
Return the BinaryMessageDecoder instance used by this class.
|
Modifier and Type | Method and Description |
---|---|
static ComplexPayloadAvro.Builder |
ComplexPayloadAvro.newBuilder(ComplexPayloadAvro other)
Creates a new ComplexPayloadAvro RecordBuilder by copying an existing ComplexPayloadAvro instance.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.