Package org.apache.avro

Examples of org.apache.avro.AvroRuntimeException

61
62
63
64
65
66
67
68
69
70
71
    if (null != this.sink) {
      if ( pos > 0) {
        try {
          flushBuffer();
        } catch (IOException e) {
          throw new AvroRuntimeException("Failure flushing old output", e);
        }
      }
    }
    this.sink = new OutputStreamSink(out);
    pos = 0;
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
    String value = (String)readString(null, in);
    if (c != null)                                // Stringable annotated class
      try {                                       // use String-arg ctor
        return c.getConstructor(String.class).newInstance(value);
      } catch (NoSuchMethodException e) {
        throw new AvroRuntimeException(e);
      } catch (InstantiationException e) {
        throw new AvroRuntimeException(e);
      } catch (IllegalAccessException e) {
        throw new AvroRuntimeException(e);
      } catch (InvocationTargetException e) {
        throw new AvroRuntimeException(e);
      }
    return value;
  }
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
      if (capacity != 0)
        elements = new Object[capacity];
    }
    public Array(Schema schema, Collection<T> c) {
      if (schema == null || !Type.ARRAY.equals(schema.getType()))
        throw new AvroRuntimeException("Not an array schema: "+schema);
      this.schema = schema;
      if (c != null) {
        elements = new Object[c.size()];
        addAll(c);
      }
View Full Code Here
74
75
76
77
78
79
80
  public DataFileWriter(DatumWriter<D> dout) {
    this.dout = dout;
  }
 
  private void assertOpen() {
    if (!isOpen) throw new AvroRuntimeException("not open");
  }
View Full Code Here
77
78
79
80
81
82
83
 
  private void assertOpen() {
    if (!isOpen) throw new AvroRuntimeException("not open");
  }
  private void assertNotOpen() {
    if (isOpen) throw new AvroRuntimeException("already open");
  }
View Full Code Here
216
217
218
219
220
221
222
223
224
  }

  /** Set a metadata property. */
  public DataFileWriter<D> setMeta(String key, byte[] value) {
    if (isReservedMeta(key)) {
      throw new AvroRuntimeException("Cannot set reserved meta key: " + key);
    }
    return setMetaInternal(key, value);
  }
View Full Code Here
153
154
155
156
157
158
159
160
    case LONG:    return in.readLong();
    case FLOAT:   return in.readFloat();
    case DOUBLE:  return in.readDouble();
    case BOOLEAN: return in.readBoolean();
    case NULL:    in.readNull(); return null;
    default: throw new AvroRuntimeException("Unknown type: " + expected);
    }
  }
View Full Code Here
233
234
235
236
237
238
239
240
241
242
243
      LOG.debug("Handshake match = NONE");
      setRemote(handshake);
      sendLocalText = true;
      break;
    default:
      throw new AvroRuntimeException("Unexpected match: "+handshake.match);
    }
   
    RPCContext context = new RPCContext();
    context.setHandshakeResponse(handshake);
    for (RPCPlugin plugin : rpcMetaPlugins) {
View Full Code Here
438
439
440
441
442
443
444
445
446
447
     */
    public Message getMessage() {
      if (message == null) {
        message = getLocal().getMessages().get(messageName);
        if (message == null) {
          throw new AvroRuntimeException("Not a local message: "+messageName);
        }
      }
      return message;
    }
View Full Code Here
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
    public Object getResponse()
      throws Exception {
      Message lm = request.getMessage();
      Message rm = remote.getMessages().get(request.getMessageName());
      if (rm == null)
        throw new AvroRuntimeException
          ("Not a remote message: "+request.getMessageName());

      Transceiver t = getTransceiver();
      if ((lm.isOneWay() != rm.isOneWay()) && t.isConnected())
        throw new AvroRuntimeException
          ("Not both one-way messages: "+request.getMessageName());

      if (lm.isOneWay() && t.isConnected()) return null; // one-way w/ handshake
     
      RPCContext context = request.getContext();
View Full Code Here
TOP

Related Classes of org.apache.avro.AvroRuntimeException

  • com.adgear.anoa.avro.ThriftDataModified
  • com.datasalt.pangool.io.Schema$Field$Props
  • HTServer$Responder
  • krati.store.avro.protocol.MultiTenantStoreResponder
  • krati.store.avro.protocol.StoreResponder
  • krati.store.bus.client.StoreBusClientImpl
  • krati.store.bus.protocol.StoreBusResponder
  • org.apache.avro.data.Json
  • org.apache.avro.data.RecordBuilderBase
  • org.apache.avro.file.CodecFactory
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.