spark/serializer/TestJavaSerializerImpl.java

0001 /*
0002  * Licensed to the Apache Software Foundation (ASF) under one or more
0003  * contributor license agreements.  See the NOTICE file distributed with
0004  * this work for additional information regarding copyright ownership.
0005  * The ASF licenses this file to You under the Apache License, Version 2.0
0006  * (the "License"); you may not use this file except in compliance with
0007  * the License.  You may obtain a copy of the License at
0008  *
0009  *    http://www.apache.org/licenses/LICENSE-2.0
0010  *
0011  * Unless required by applicable law or agreed to in writing, software
0012  * distributed under the License is distributed on an "AS IS" BASIS,
0013  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
0014  * See the License for the specific language governing permissions and
0015  * limitations under the License.
0016  */
0017
0018 package org.apache.spark.serializer;
0019
0020 import java.io.InputStream;
0021 import java.io.OutputStream;
0022 import java.nio.ByteBuffer;
0023
0024 import scala.reflect.ClassTag;
0025
0026
0027 /**
0028  * A simple Serializer implementation to make sure the API is Java-friendly.
0029  */
0030 class TestJavaSerializerImpl extends Serializer {
0031
0032   @Override
0033   public SerializerInstance newInstance() {
0034     return null;
0035   }
0036
0037   static class SerializerInstanceImpl extends SerializerInstance {
0038       @Override
0039       public <T> ByteBuffer serialize(T t, ClassTag<T> evidence$1) {
0040         return null;
0041       }
0042
0043       @Override
0044     public <T> T deserialize(ByteBuffer bytes, ClassLoader loader, ClassTag<T> evidence$1) {
0045       return null;
0046     }
0047
0048     @Override
0049     public <T> T deserialize(ByteBuffer bytes, ClassTag<T> evidence$1) {
0050       return null;
0051     }
0052
0053     @Override
0054     public SerializationStream serializeStream(OutputStream s) {
0055       return null;
0056     }
0057
0058     @Override
0059     public DeserializationStream deserializeStream(InputStream s) {
0060       return null;
0061     }
0062   }
0063
0064   static class SerializationStreamImpl extends SerializationStream {
0065
0066     @Override
0067     public <T> SerializationStream writeObject(T t, ClassTag<T> evidence$1) {
0068       return null;
0069     }
0070
0071     @Override
0072     public void flush() {
0073
0074     }
0075
0076     @Override
0077     public void close() {
0078
0079     }
0080   }
0081
0082   static class DeserializationStreamImpl extends DeserializationStream {
0083
0084     @Override
0085     public <T> T readObject(ClassTag<T> evidence$1) {
0086       return null;
0087     }
0088
0089     @Override
0090     public void close() {
0091
0092     }
0093   }
0094 }