Getting Started

// an example of instantiating a remote proxy

Routing is the property inside a space class that says how objects will be distributed across partitions, there is also a strategy that instead of distributing you can replicate the table data across all partitions for small tables.

@SpaceClass public class Account { Integer accountID; String accountName; @SpaceRouting public Integer getAccountID() { return accountID; } public String getAccountName() { return accountName; } // setter methods ... }

Data Partitioning Practical

Broadcast Objects

Colocated logic can contain event processing, code for services, and any application bean that should run together within the Space partition, in the example provided, you can see colocated event containers and remote service exposure

In your installation folder you will find examples of event processing:

<GS_HOME>\examples\data-app\event-processing

Polling Container Overview

// change api gigaSpace.change(sqlQuery, new ChangeSet().increment("price", new BigDecimal(5)));

public class MyDistTask implements DistributedTask<Integer, Long> { public Integer execute() throws Exception { return 1; } public Long reduce(List<AsyncResult<Integer>> results) throws Exception { long sum = 0; for (AsyncResult<Integer> result : results) { if (result.getException() != null) { throw result.getException(); } sum += result.getResult(); } return sum; } }

With event processing you can build workflows, moving related object from one state to the other and define listeners per state

Event Processing

You can perform an initial load into the Space from a data source and can replicate changes in memory to a target (database, Kafka Apache Kafka is a distributed event store and stream-processing platform. Apache Kafka is a distributed publish-subscribe messaging system. A message is any kind of information that is sent from a producer (application that sends the messages) to a consumer (application that receives the messages). Producers write their messages or data to Kafka topics. These topics are divided into partitions that function like logs. Each message is written to a partition and has a unique offset, or identifier. Consumers can specify a particular offset point where they can begin to read messages.). Refer to the blueprint Java project templating framework provided by DIH for developers, a bueprint, or class, contains a set of attributes and behaviors that define an object. example (see #2 above) of how to load data from a relational database using hibernate integration and how to replicate data to that database, similar can be done with other kinds of sources such as MongoDB, Cassandara and Kafka.

stateful-with-db BluePrint

Creating a PU

Deploy your Services in Service Grid

XAP only

Deploy with REST REpresentational State Transfer. Application Programming Interface An API, or application programming interface, is a set of rules that define how applications or devices can connect to and communicate with each other. A REST API is an API that conforms to the design principles of the REST, or representational state transfer architectural style., CLI, OPS-UI, Admin code

Deploy your Services in Kubernetes

XAP Skyline only

Deploying a Customer Processing Unit

• Out of the box XAP Skyline is stateless so there is no need to create new stateless custom PUs as they have no added value.  However, when migrating from XAP to XAP Skyline there will already be stateless PUs defined and theses can be deployed and do not need to be recreated.

• Creating Client Services in Kubernetes (refer to the README)