Package | Description |
---|---|
org.apache.flink.streaming.tests.avro |
Modifier and Type | Method and Description |
---|---|
InnerPayLoadAvro |
InnerPayLoadAvro.Builder.build() |
static InnerPayLoadAvro |
InnerPayLoadAvro.fromByteBuffer(ByteBuffer b)
Deserializes a InnerPayLoadAvro from a ByteBuffer.
|
InnerPayLoadAvro |
ComplexPayloadAvro.getInnerPayLoad()
Gets the value of the 'innerPayLoad' field.
|
InnerPayLoadAvro |
ComplexPayloadAvro.Builder.getInnerPayLoad()
Gets the value of the 'innerPayLoad' field.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.avro.message.BinaryMessageDecoder<InnerPayLoadAvro> |
InnerPayLoadAvro.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<InnerPayLoadAvro> |
InnerPayLoadAvro.getDecoder()
Return the BinaryMessageDecoder instance used by this class.
|
static org.apache.avro.message.BinaryMessageEncoder<InnerPayLoadAvro> |
InnerPayLoadAvro.getEncoder()
Return the BinaryMessageEncoder instance used by this class.
|
Modifier and Type | Method and Description |
---|---|
static InnerPayLoadAvro.Builder |
InnerPayLoadAvro.newBuilder(InnerPayLoadAvro other)
Creates a new InnerPayLoadAvro RecordBuilder by copying an existing InnerPayLoadAvro instance.
|
void |
ComplexPayloadAvro.setInnerPayLoad(InnerPayLoadAvro value)
Sets the value of the 'innerPayLoad' field.
|
ComplexPayloadAvro.Builder |
ComplexPayloadAvro.Builder.setInnerPayLoad(InnerPayLoadAvro value)
Sets the value of the 'innerPayLoad' field.
|
Constructor and Description |
---|
ComplexPayloadAvro(Long eventTime,
List<String> stringList,
String strPayload,
InnerPayLoadAvro innerPayLoad)
All-args constructor.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.