bvdeenen

0x8C0b7c0c3b3c51c58de179326a2307D769E3ed27

bvdeenen

// the gist of my deserialize
private DatumReader<GenericRecord> reader;
reader = new SpecificDatumReader<>(writerSchema, readerSchema);

GenericRecord deserialize(byte[] msg) throws IOException, IllegalStateException
{
  BinaryDecoder decoder = DecoderFactory.get().binaryDecoder(msg, null);
  return reader.read(null, decoder);
}

bvdeenen

/**
 * Autogenerated by Avro
 * 
 * DO NOT EDIT DIRECTLY
 */
package com.kpn.datalab.schemas.omnicrm.contact_history.v1;  
@SuppressWarnings("all")
@org.apache.avro.specific.AvroGenerated
public class contactHistory extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord {
  public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"contactHistory\",\"namespace\":\"com.kpn.datalab.schemas.omnicrm.contact_history.v1\",\"fields\":[{\"name\":\"events\",\"type\":{\"type\":\"array\",\"items\":\"bytes\"}},{\"name\":\"krn\",\"type\":\"string\"}]}");

bvdeenen

[source,cypher]
----
CREATE (DB1:Database {backbone: true, name:"postgres db 1"})
CREATE (Ingest1:Ingest {backbone: true, name: "ingest-1"})

CREATE (KV1:KV {name: "key-value store 1"})
CREATE (KV2:KV {name: "key-value store 2"})
CREATE (KV1)-[:requires]->(DB1)
CREATE (KV2)-[:requires]->(DB1)
CREATE (Topic1:Topic {name: "topic-1", partitions:100})

bvdeenen

sysPath=require('path');

files=['a','b','c'];
parent= "yo";

myjoin = function(a,b){return sysPath.join(a,b);}

console.log(files.map( myjoin.bind(null, parent) )); // works fine
console.log(files.map( sysPath.join.bind(null, parent) )); // throws exception