Examples of PrimaryKeySchema

    if(pkFieldName == null)
    {
      throw new DatabusException("No primary key specified in the schema");
    }


    PrimaryKeySchema pkSchema = new PrimaryKeySchema(pkFieldName);
    List<Schema.Field> fields = schema.getFields();
    List<KeyPair> kpl = new ArrayList<KeyPair>();
    int cnt = 0;
    for(Schema.Field field : fields)
    {
      if (pkSchema.isPartOfPrimaryKey(field))
      {
        o = cl.get(cnt).getValue();
        st = field.schema().getType();
        KeyPair kp = new KeyPair(o, st);
        kpl.add(kp);

Examples of com.linkedin.databus2.producers.ds.PrimaryKeySchema

    if(keyName == null)
    {
      throw new DatabusException("The event schema is missing the required field \"key\".");
    }


    _pKeySchema = new PrimaryKeySchema(keyName);
  }

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.