/* * Copyright 2018 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). You may * not use this file except in compliance with the License. A copy of the * License is located at * * http://aws.amazon.com/apache2.0/ * * or in the "license" file accompanying this file. This file is distributed * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either * express or implied. See the License for the specific language governing * permissions and limitations under the License. */ package com.amazonaws.events.kinesis; import org.apache.flink.streaming.util.serialization.DeserializationSchema; import org.apache.flink.api.common.typeinfo.TypeInformation; import org.apache.flink.api.java.typeutils.TypeExtractor; /** * A simple class for deserialize the incoming Kinesis stream records * using the deprecated DeserializationSchema class * * @see https://github.com/apache/flink/pull/5069 */ public class EventSchema implements DeserializationSchema { @Override public Event deserialize(byte[] bytes) { return Event.parseEvent(bytes); } @Override public boolean isEndOfStream(Event event) { return false; } @Override public TypeInformation getProducedType() { return TypeExtractor.getForClass(Event.class); } }