List of binaryDecoder() Examples

Examples of binaryDecoder()

org.apache.avro.io.DecoderFactory.binaryDecoder()
Creates or reinitializes a {@link BinaryDecoder} with the input streamprovided as the source of data. If reuse is provided, it will be reinitialized to the given input stream.
{@link BinaryDecoder} instances returned by this method buffer their input,reading up to {@link #getConfiguredBufferSize()} bytes past the minimumrequired to satisfy read requests in order to achieve better performance. If the buffering is not desired, use {@link #directBinaryDecoder(InputStream,BinaryDecoder)}.
{@link BinaryDecoder#inputStream()} provides a view on the data that isbuffer-aware, for users that need to interleave access to data with the Decoder API. @param in The InputStream to initialize to @param reuse The BinaryDecoder to attempt to reuse given the factory configuration. A BinaryDecoder implementation may not be compatible with reuse, causing a new instance to be returned. If null, a new instance is returned. @return A BinaryDecoder that uses in as its source of data. Ifreuse is null, this will be a new instance. If reuse is not null, then it may be reinitialized if compatible, otherwise a new instance will be returned. @see BinaryDecoder @see Decoder

Examples of org.apache.avro.io.DecoderFactory.binaryDecoder()

      fos.close();
    }
    {
      FileInputStream fis = new FileInputStream(file);
      DecoderFactory factory = new DecoderFactory();
      BinaryDecoder bd = factory.binaryDecoder(fis, null);
      SpecificDatumReader<User> sdr = new SpecificDatumReader<User>(User.class);
      User loaded = sdr.read(null, bd);
      fis.close();
      assertEquals(saved, loaded);
      assertEquals("Sam", loaded.firstName.toString());

View Full Code Here

Examples of org.apache.avro.io.DecoderFactory.binaryDecoder()

      fos.close();
    }
    {
      FileInputStream fis = new FileInputStream(file);
      DecoderFactory factory = new DecoderFactory();
      BinaryDecoder bd = factory.binaryDecoder(fis, null);
      SpecificDatumReader<User> sdr = new SpecificDatumReader<User>(User.class);
      User loaded = sdr.read(null, bd);
      fis.close();
      assertEquals(saved, loaded);
      assertEquals(null, loaded.location);

View Full Code Here

Examples of org.apache.avro.io.DecoderFactory.binaryDecoder()

          case JSON:
            d = decoderFactory.jsonDecoder(schema, is);
            break;
          case BINARY:
          default:
            d = decoderFactory.binaryDecoder(is, null);
            break;
        }
        // Read the data
        SpecificDatumReader<T> sdr = new SpecificDatumReader<T>(schema);
        sdr.setExpected(actualSchema);

View Full Code Here

Examples of org.apache.avro.io.DecoderFactory.binaryDecoder()

              if (len > valuebytes.length) {
                valuebytes = new byte[len];
              }
              dis.readFully(valuebytes, 0, len);
              DecoderFactory decoderFactory = new DecoderFactory();
              Decoder d = decoderFactory.binaryDecoder(new ByteArrayInputStream(valuebytes, 0, len), null);
              // Read the data
              SpecificDatumReader<Beacon> sdr = new SpecificDatumReader<Beacon>(writerSchema, Beacon.SCHEMA$);
              Beacon read = sdr.read(null, d);
              beaconFAB.put(row, read);
            }

View Full Code Here

TOP

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.