Package | Description |
---|---|
org.apache.flink.streaming.tests.artificialstate |
Modifier and Type | Method and Description |
---|---|
ComplexPayload |
StatefulComplexPayloadSerializer.copy(ComplexPayload from) |
ComplexPayload |
StatefulComplexPayloadSerializer.copy(ComplexPayload from,
ComplexPayload reuse) |
ComplexPayload |
StatefulComplexPayloadSerializer.createInstance() |
ComplexPayload |
StatefulComplexPayloadSerializer.deserialize(ComplexPayload reuse,
DataInputView source) |
ComplexPayload |
StatefulComplexPayloadSerializer.deserialize(DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<ComplexPayload> |
StatefulComplexPayloadSerializer.duplicate() |
Modifier and Type | Method and Description |
---|---|
ComplexPayload |
StatefulComplexPayloadSerializer.copy(ComplexPayload from) |
ComplexPayload |
StatefulComplexPayloadSerializer.copy(ComplexPayload from,
ComplexPayload reuse) |
ComplexPayload |
StatefulComplexPayloadSerializer.deserialize(ComplexPayload reuse,
DataInputView source) |
void |
StatefulComplexPayloadSerializer.serialize(ComplexPayload record,
DataOutputView target) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.