public class KryoTupleSerializer extends Object implements ITupleSerializer
| Constructor and Description |
|---|
KryoTupleSerializer(Map<String,Object> conf,
GeneralTopologyContext context) |
public KryoTupleSerializer(Map<String,Object> conf, GeneralTopologyContext context)
public byte[] serialize(Tuple tuple)
serialize in interface ITupleSerializerCopyright © 2021 The Apache Software Foundation. All rights reserved.