Class ByteArraySchema
- java.lang.Object
-
- uk.gov.gchq.gaffer.flink.operation.handler.serialisation.ByteArraySchema
-
- All Implemented Interfaces:
Serializable
,org.apache.flink.api.common.serialization.DeserializationSchema<byte[]>
,org.apache.flink.api.java.typeutils.ResultTypeQueryable<byte[]>
,org.apache.flink.streaming.util.serialization.DeserializationSchema<byte[]>
public class ByteArraySchema extends Object implements org.apache.flink.streaming.util.serialization.DeserializationSchema<byte[]>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ByteArraySchema()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte[]
deserialize(byte[] bytes)
org.apache.flink.api.common.typeinfo.TypeInformation<byte[]>
getProducedType()
boolean
isEndOfStream(byte[] bytes)
-
-
-
Method Detail
-
deserialize
public byte[] deserialize(byte[] bytes) throws IOException
- Specified by:
deserialize
in interfaceorg.apache.flink.api.common.serialization.DeserializationSchema<byte[]>
- Specified by:
deserialize
in interfaceorg.apache.flink.streaming.util.serialization.DeserializationSchema<byte[]>
- Throws:
IOException
-
isEndOfStream
public boolean isEndOfStream(byte[] bytes)
- Specified by:
isEndOfStream
in interfaceorg.apache.flink.api.common.serialization.DeserializationSchema<byte[]>
- Specified by:
isEndOfStream
in interfaceorg.apache.flink.streaming.util.serialization.DeserializationSchema<byte[]>
-
getProducedType
public org.apache.flink.api.common.typeinfo.TypeInformation<byte[]> getProducedType()
- Specified by:
getProducedType
in interfaceorg.apache.flink.api.java.typeutils.ResultTypeQueryable<byte[]>
-
-