Package org.apache.avro

Examples of org.apache.avro.AvroRuntimeException

77
78
79
80
81
82
83
  public DataFileWriter(DatumWriter<D> dout) {
    this.dout = dout;
  }
 
  private void assertOpen() {
    if (!isOpen) throw new AvroRuntimeException("not open");
  }
View Full Code Here
80
81
82
83
84
85
86
 
  private void assertOpen() {
    if (!isOpen) throw new AvroRuntimeException("not open");
  }
  private void assertNotOpen() {
    if (isOpen) throw new AvroRuntimeException("already open");
  }
View Full Code Here
249
250
251
252
253
254
255
256
257
  }

  /** 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
205
206
207
208
209
210
211
212
      }
      return blockRemaining != 0;
    } catch (EOFException e) {                    // at EOF
      return false;
    } catch (IOException e) {
      throw new AvroRuntimeException(e);
    }
  }
View Full Code Here
217
218
219
220
221
222
223
224
  @Override
  public D next() {
    try {
      return next(null);
    } catch (IOException e) {
      throw new AvroRuntimeException(e);
    }
  }
View Full Code Here
270
271
272
273
274
275
276
277
      availableBlock = true;
      return true;
    } catch (EOFException eof) {
      return false;
    } catch (IOException e) {
      throw new AvroRuntimeException(e);
    }
  }
View Full Code Here
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
  public Record build() {
    Record record;
    try {
      record = new GenericData.Record(schema());
    } catch (Exception e) {
      throw new AvroRuntimeException(e);
    }
   
    for (Field field : fields()) {
      Object value;
      try {
        value = getWithDefault(field);
      } catch(IOException e) {
        throw new AvroRuntimeException(e);
      }
      if (value != null) {
        record.put(field.pos(), value);
      }
    }
View Full Code Here
351
352
353
354
355
356
357
 
  // default encoder is not mutable
  private static class DefaultEncoderFactory extends EncoderFactory {
    @Override
    public EncoderFactory configureBlockSize(int size) {
      throw new AvroRuntimeException("Default EncoderFactory cannot be configured");
    }
View Full Code Here
355
356
357
358
359
360
361
    public EncoderFactory configureBlockSize(int size) {
      throw new AvroRuntimeException("Default EncoderFactory cannot be configured");
    }
    @Override
    public EncoderFactory configureBufferSize(int size) {
      throw new AvroRuntimeException("Default EncoderFactory cannot be configured");
    }
View Full Code Here
400
401
402
403
404
405
406
407
    case LONG:    return datum instanceof Long;
    case FLOAT:   return datum instanceof Float;
    case DOUBLE:  return datum instanceof Double;
    case BOOLEAN: return datum instanceof Boolean;
    case NULL:    return datum == null;
    default: throw new AvroRuntimeException("Unexpected type: " +schema);
    }
  }
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.