RADAR Schemas Java SDK

The Java SDKs are published as JARs on Maven Central. To use them in Gradle, add the following code to your build.gradle:

repositories {
    mavenCentral()
    maven { url 'https://packages.confluent.io/maven/' }
    maven { url "https://jitpack.io" }
}

dependencies {
    // Compiled Avro schemas
    compile 'org.radarbase:radar-schemas-commons:<release version>'

    // Specification loader and schema validation library
    compile 'org.radarbase:radar-schemas-core:<release version>'

    // Register topics and schemas
    compile 'org.radarbase:radar-schemas-registration:<release version>'
}

Usually, you only need to include the schemas you actually need in your dependencies.

The generated code each refers to a single schema. The classes of Avro records will extend org.apache.avro.specific.SpecificRecord. They each have a static getClassSchema() function that returns the Schema that it was generated from. To read JSON serialized data for example, use the following code:

public class Deserialize {
   public PhoneBatteryLevel deserializeBatteryLevel(InputStream json) throws Exception {
      //Instantiating the Schema.Parser class.
      DatumReader<PhoneBatteryLevel> datumReader = new SpecificDatumReader<>(PhoneBatteryLevel.class);
      Decoder decoder = new DecoderFactory().jsonDecoder(PhoneBatteryLevel.getClassSchema(), outputStream);
      return datumReader.read(null, decoder);
   }
}

Alternatively, use org.radarcns.data.SpecificRecordEncoder and org.radarcns.data.SpecificRecordDecoder from the radar-commons package.

Tools

This distribution also contains two java applications: radar-schemas-tools and radar-catalog-server. The former is used to validate schemas and specifications, register topics and schemas, or list available topics. The latter hosts all source types from the specification as an API.