/**
* Defines the interface for all the Java transformation processors that
* need to perform operations in a non-delete context.
*/
public interface IJavaAllUpdatesTransformationProcessor extends IJavaTransformationProcessor {
/**
* Performs the add or update operations of the client’s processor for the
* the document transmitted, with the help of the handler provided.
* @param handler The transformation handler providing the allowed operations for the processor.
* @param document The reference document.
* @throws Exception Occurs for whatever reason in the client's implementation.
* The exception will most likely be wrapped with contextual information before further propagation.
*/
public void process(final IJavaAllUpdatesTransformationHandler handler,
final IMutableTransformationDocument document) throws Exception;
}

/**
* Defines the common operations for all Java transformation processors.
*/
public interface IJavaTransformationProcessor extends CVComponent {
/**
* Returns a document type on which the processor will perform a transformation.
* If one returns null or an empty string, then it will be applied on all source documents.
* @return A valid document type or null or empty string.
*/
public String getTransformationDocumentType();
}

@CVComponentDescription("My First Transformation Processor Component")
@CVPluginVersion("1.0")
@CVComponentConfigClass(configClass=MyComponentConfig.class)
public class MyFirstTransformationProcessor implements IJavaAllUpdatesTransformationProcessor {
public MyFirstTransformationProcessor(final MyComponentConfig config) {
}

@Override
public String getTransformationDocumentType() {
return "city";
}

@Override
public void process(final IJavaAllUpdatesTransformationHandler handler,
final IMutableTransformationDocument document) throws Exception {
// Do nothing, that is transmit all "city" documents to the next processor
// or to the Consolidation Store.
logger.info("Processing " + document.getURI());
}
private final Logger logger = Logger.getLogger("app-name.conso-server.transformation");

}

public final class MyComponentConfig implements CVComponentConfig {
// No property defined
}

/**
* Defines the interface for all Java aggregation processors that need to perform document operations
* in a non-delete context.
*/
public interface IJavaAllUpdatesAggregationProcessor extends IJavaAggregationProcessor {
/**
* Performs the aggregation operations of the client's processor for the document transmitted,
* with the help of the handler provided.
*
* @param handler The aggregation handler with the allowed operations for the processor.
* @param document The reference document.
* @throws Exception Occurs for whatever reason in the client's implementation.
* The exception will most likely be wrapped with contextual information before further propagation.
*/
public void process(final IJavaAllUpdatesAggregationHandler handler, final IAggregationDocument document)
throws Exception;
}

/**
* Defines the interface for all Java aggregation processors that need to
* perform document operations in a non-delete context.
*/
public interface IJavaAllUpdatesAggregationProcessor extends IJavaAggregationProcessor {
/**
* Performs the aggregation operations of the client's processor for the document transmitted,
* with the help of the handler provided.
*
* @param handler The aggregation handler with the allowed operations for the processor.
* @param document The reference document.
* @throws Exception Occurs for whatever reason in the client's implementation.
* The exception will most likely be wrapped with contextual information before further propagation.
*/
public void process(final IJavaAllUpdatesAggregationHandler handler, final IAggregationDocument document)
throws Exception;
}

/**
* Defines the interface for all Java aggregation processors that need to perform delete
* processing on documents.
*/
public interface IJavaDeleteAggregationProcessor extends IJavaAggregationProcessor {
/**
* Performs the aggregation operations of the client's processor for the document transmitted,
* with the help of the handler provided.
*
* @param handler The aggregation handler with the allowed operations for the processor.
* @param document The reference document.
* @throws Exception Occurs for whatever reason in the client's implementation.
* The exception will most likely be wrapped with contextual information before further propagation.
*/
public void process(final IJavaDeleteAggregationHandler handler, final IAggregationDocument document)
throws Exception;}

@CVComponentConfigClass(configClass=CVComponentConfigNone.class)
public class EmployeeTransformationProcessor implements IJavaAllUpdatesTransformationProcessor {
public EmployeeTransformationProcessor(final CVComponentConfigNone config) {
}

@Override
public String getTransformationDocumentType() {
return "employee";
}

@Override
public void process(final IJavaAllUpdatesTransformationHandler handler,
final IMutableTransformationDocument document) throws Exception {
final String companyName = document.getMeta("company_name");
final String serviceName = document.getMeta("service_name");
if ((companyName != null) && (! companyName.isEmpty()) && (serviceName != null) &&
(! serviceName.isEmpty())) {
final ITransformationDocument serviceDoc = addService(handler, document, serviceName, companyName);
document.addArcTo("employee", serviceDoc.getUri());
}
}
private ITransformationDocument addService(final IJavaAllUpdatesTransformationHandler handler,
final IMutableTransformationDocument document, final String serviceName, final String companyName) {
final IMutableTransformationDocument newDoc = handler.createDocument("service=" + serviceName + "&",
"service");
newDoc.addArcTo("service", "company=" + companyName + "&");
handler.yield(newDoc);
// Note that the yield here is required because it is a document created
// during the Transformation phase
return newDoc;
}
}

...
@Override
public void process(final IJavaAllUpdatesTransformationHandler handler,
final IMutableTransformationDocument document) throws Exception {
final String serviceName = document.getMeta("service_name");
if ((companyName != null) && (! companyName.isEmpty()) && (serviceName != null) &&
(! serviceName.isEmpty())) {
document.addArcTo("employee", "service=" + serviceName + "_" + companyName + "&");
}
}
...

final PushAPI employeePushAPI = CloudviewAPIClientsFactory.newInstance(GATEWAY_URL).newPushAPI
(PUSH_API_SERVER, CONNECTOR_NAME);
final List<Document> employees = new ArrayList<Document>();

Document employee = new Document("employee=Alice&");
employee.addMeta("company_name", "3ds");
employee.addMeta("service_name", "RandD");

employees.add(employee);

employee = new Document("employee=Bob&");
employee.addMeta("company_name", "3ds");
employee.addMeta("service_name", "RandD");

employees.add(employee);

employee = new Document("employee=John&");
employee.addMeta("company_name", "3ds");
employee.addMeta("service_name", "Sales");

employees.add(employee);
final Iterator<Document> employeesIt = employees.iterator();
while (employeesIt.hasNext()) {employee = employeesIt.next();
final String serviceURI = getServiceURI(employee.getMetaContainer().getMeta("service_name").getValue());
// Create service managed document
PushAPITransformationHelpers.createDocument(employee, serviceURI, "service");

// Add arc from employee to service
PushAPITransformationHelpers.addArcTo(employee, "employee", serviceURI);

// Add arc from service to company
final String companyURI = getCompanyURI(employee.getMetaContainer().getMeta("company_name").getValue());
PushAPITransformationHelpers.addArcTo(employee, "service", serviceURI, companyURI);
employeePushAPI.addDocument(employee);
}

@CVComponentConfigClass(configClass=CVComponentConfigNone.class)
public final class CompanyAggregationProcessor implements IJavaAllUpdatesAggregationProcessor {
public CompanyAggregationProcessor(final CVComponentConfigNone config) {
}
@Override
public String getAggregationDocumentType() {
return "company";
}

@Override
public void process(final IJavaAllUpdatesAggregationHandler handler, final IAggregationDocument document)
throws Exception {
int nbEmployees = 0;
for (final IAggregationDocument serviceDoc : GraphMatchHelpers.getPathsEnd(handler.match(document,
"-service"))) {
nbEmployees += handler.match(serviceDoc, "-employee").size();
}
document.withMeta("nb_employees", String.valueOf(nbEmployees));
}
}

handler.match(document, "-service")

public static <T> List<T> getPathsEnd(final List<List<T>> paths) {
return Lists.transform(paths, new Function<List<T>, T>() {
@Override
public T apply(final List<T> path) {
return Iterables.getLast(path);
}
});
}

handler.match(serviceDoc, "-employee").size()

@CVComponentConfigClass(configClass=CVComponentConfigNone.class)
public final class CompanyAggregationProcessor implements IJavaAllUpdatesAggregationProcessor {
public CompanyAggregationProcessor(final CVComponentConfigNone config) {
}

@Override
public String getAggregationDocumentType() {
return "company";
}

@Override
public void process(final IJavaAllUpdatesAggregationHandler handler, final IAggregationDocument document)
throws Exception {
int nbEmployees = handler.match(document, "-service.-employee").size()
document.withMeta("nb_employees", String.valueOf(nbEmployees));
}
}

handler.match(document, "-service.-employee")

@CVComponentConfigClass(configClass=CVComponentConfigNone.class)
public final class ServiceAggregationProcessor implements IJavaAllUpdatesAggregationProcessor {
public ServiceAggregationProcessor(final CVComponentConfigNone config) {
}

@Override
public String getAggregationDocumentType() {
return "service";
}

@Override
public void process(final IJavaAllUpdatesAggregationHandler handler, final IAggregationDocument document)
throws Exception {
document.withMeta("nb_employees", String.valueOf(handler.match(document, "-employee").size()));
}

}

@CVComponentConfigClass(configClass=CVComponentConfigNone.class)
public final class CompanyAggregationProcessor implements IJavaAllUpdatesAggregationProcessor {
public CompanyAggregationProcessor(final CVComponentConfigNone config) {
}

@Override
public String getAggregationDocumentType() {
return "company";
}
@Override
public void process(final IJavaAllUpdatesAggregationHandler handler, final IAggregationDocument document)
throws Exception {
int nbEmployees = 0;
for (final IAggregationDocument serviceDoc : GraphMatchHelpers.getPathsEnd(handler.match(document,
"-service"))) {
final String nbServiceEmployees = serviceDoc.getMeta("nb_employees");
if ((nbServiceEmployees != null) && (! nbServiceEmployees.isEmpty()) {
nbEmployees += Integer.valueOf(nbServiceEmployees);
}
}
document.withMeta("nb_employees", String.valueOf(nbEmployees));
}
}