Source code

001/*
002 * Licensed to the Apache Software Foundation (ASF) under one
003 * or more contributor license agreements.  See the NOTICE file
004 * distributed with this work for additional information
005 * regarding copyright ownership.  The ASF licenses this file
006 * to you under the Apache License, Version 2.0 (the
007 * "License"); you may not use this file except in compliance
008 * with the License.  You may obtain a copy of the License at
009 *
010 *   http://www.apache.org/licenses/LICENSE-2.0
011 *
012 * Unless required by applicable law or agreed to in writing,
013 * software distributed under the License is distributed on an
014 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
015 * KIND, either express or implied.  See the License for the
016 * specific language governing permissions and limitations
017 * under the License.
018 */
019package org.apache.reef.wake.remote.impl;
020
021import org.apache.reef.wake.remote.Codec;
022
023/**
024 * Codec of the event sent remotely.
025 *
026 * @param <T> type
027 */
028public class RemoteEventCodec<T> implements Codec<RemoteEvent<T>> {
029
030  private final RemoteEventEncoder<T> encoder;
031  private final RemoteEventDecoder<T> decoder;
032
033  /**
034   * Constructs a remote event codec.
035   *
036   * @param codec the codec for the event
037   */
038  public RemoteEventCodec(final Codec<T> codec) {
039    encoder = new RemoteEventEncoder<>(codec);
040    decoder = new RemoteEventDecoder<>(codec);
041  }
042
043  /**
044   * Encodes the remote event object to bytes.
045   *
046   * @param obj the remote event object
047   * @return bytes
048   */
049  @Override
050  public byte[] encode(final RemoteEvent<T> obj) {
051    return encoder.encode(obj);
052  }
053
054  /**
055   * Decodes a remote event object from the bytes.
056   *
057   * @param data the byte array
058   * @return a remote event object
059   */
060  @Override
061  public RemoteEvent<T> decode(final byte[] data) {
062    return decoder.decode(data);
063  }
064
065}