Data Operators #

A Data Operator in the Proxima platform is a way of accessing data defined in Data model and mapped on attribute families. It allows the conversion of the model to objects that can be used to access the data using a particular technology. Currently, the following operators exist in the platform:

• Direct Data Operator
• Beam Data Operator
• Flink Data Operator

All operators are created using #getOrCreateOperator method of Repository:

  Repository repo = Repository.of(ConfigFactory.load().resolve());
  DirectDateOperator direct = repo.getOrCreateDataOperator(DirectDataOperator.class);

Operators are loaded using ServiceLoader, so must be on classpath (or module path) when running the application. A typical base module for a data operator is proxima-<name>-core, e.g. artifact proxima-direct-core.