Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License 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 org.apache.avro.io;
 
 
An implementation of Decoder that ensures that the sequence of operations conforms to a schema.
 
 public class ValidatingDecoder extends ParsingDecoder
   implements Parser.ActionHandler {
   protected Decoder in;
 
   ValidatingDecoder(Symbol rootDecoder inthrows IOException {
     super(root);
     this. = in;
   }
 
   public ValidatingDecoder(Schema schemaDecoder inthrows IOException {
     this(new ValidatingGrammarGenerator().generate(schema), in);
   }
 
   @Override
   public void init(InputStream inthrows IOException {
     .reset();
     this..init(in);
   }
 
   @Override
   public void readNull() throws IOException {
     .readNull();
   }
     
   @Override
   public boolean readBoolean() throws IOException {
     return .readBoolean();
   }
 
   @Override
   public int readInt() throws IOException {
     return .readInt();
   }
     
   @Override
   public long readLong() throws IOException {
     return .readLong();
   }
 
   @Override
   public float readFloat() throws IOException {
     return .readFloat();
   }
 
   @Override
   public double readDouble() throws IOException {
     return .readDouble();
   }
     
   @Override
   public Utf8 readString(Utf8 oldthrows IOException {
     return .readString(old);
   }
 
   @Override
   public void skipString() throws IOException {
     .skipString();
  }
  public ByteBuffer readBytes(ByteBuffer oldthrows IOException {
    return .readBytes(old);
  }
  public void skipBytes() throws IOException {
    .skipBytes();
  }
  private void checkFixed(int sizethrows IOException {
    if (size != top.size) {
      throw new AvroTypeException(
        "Incorrect length for fixed binary: expected " +
        top.size + " but received " + size + " bytes.");
    }
  }
    
  public void readFixed(byte[] bytesint startint lenthrows IOException {
    checkFixed(len);
    .readFixed(bytesstartlen);
  }
  public void skipFixed(int lengththrows IOException {
    checkFixed(length);
    .skipFixed(length);
  }
  protected void skipFixed() throws IOException {
    .skipFixed(top.size);
  }
  public int readEnum() throws IOException {
    int result = .readEnum();
    if (result < 0 || result >= top.size) {
      throw new AvroTypeException(
          "Enumeration out of range: max is " +
          top.size + " but received " + result);
    }
    return result;
  }
  public long readArrayStart() throws IOException {
    long result = .readArrayStart();
    if (result == 0) {
    }
    return result;
  }
  public long arrayNext() throws IOException {
    long result = .arrayNext();
    if (result == 0) {
    }
    return result;
  }
  public long skipArray() throws IOException {
    for (long c = .skipArray(); c != 0; c = .skipArray()) {
      while (c-- > 0) {
        .skipRepeater();
      }
    }
    .advance(.);    
    return 0;
  }
  public long readMapStart() throws IOException {
    long result = .readMapStart();
    if (result == 0) {
    }
    return result;
  }
  public long mapNext() throws IOException {
    long result = .mapNext();
    if (result == 0) {
    }
    return result;
  }
  public long skipMap() throws IOException {
    for (long c = .skipMap(); c != 0; c = .skipMap()) {
      while (c-- > 0) {
        .skipRepeater();
      }
    }
    return 0;
  }
  public int readIndex() throws IOException {
    int result = .readIndex();
    .pushSymbol(top.getSymbol(result));
    return result;
  }
  
  public Symbol doAction(Symbol inputSymbol topthrows IOException {
    return null;
  }
New to GrepCode? Check out our FAQ X