Infinispan-avro

Description

This project offers an Infinispan support for Apache Avro, providing the ability to store and query Avro defined types with the help of Infinispan query DSL.

This project is also intended to be used in conjunction with the Infinispan support for Apache Gora, in order to execute Hadoop map-reduce tasks on top of Infinispan.

Installation

This project is based upon Maven and makes use of Infinispan 7.2.5.Final. Below, we explain how to install the Avro support for Infinispan.

git clone https://github.com/leads-project/infinispan-avro.git
cd infinispan-avro
mvn clean install -DskipTests

Usage

Storing, retrieving and Querying Avro defined types requires to start a HotRod server, while enabling the infinispan-avro-server module. Then, the client side should use the infinispan-avro-hotorod module to construct its query .

To build an Avro defined type, please refer to the Apache Avro documentation on the compiler.

Code Sample

Let Employee be an Avro defined type. The following code illustrates how to store and query Employee instances.

import example.avro.Employee;
import org.infinispan.avro.hotrod.Search;
import org.infinispan.query.dsl.Query;
import org.infinispan.query.dsl.QueryFactory;
...

Employee employee = new Employee();
employee.setName("Pierre");
employee.setSalary(5000);
employee.setSsn("12478");
employee.setDateOfBirth((long) 200991);

remotecache.put(1,employee);

QueryFactory qf = Search.getQueryFactory(remoteCache1);

Query query = qf.from(Employee.class)
                .having("ssn").eq("12478").toBuilder()
                .build();
List<Employee> list = query.list();
assertNotNull(list);
assertEquals(1, list.size());

Every field of an Avro defined type with a (String converted) length smaller than 1000 bytes can be queried through the DSL. As with original HotRod queries, a query is executed locally at the server that receives it.