Storing Streaming Data - Real-Time Analytics - page 274

camus-kafka-0.8
from origin.
Switched to a new branch 'camus-kafka-0.8'
$ mvn install
After the Maven packages have been locally installed, they can be used in a
custom loader project's Maven file:
<dependencies>
<dependency>
<groupId>com.linkedin.camus</groupId>
<artifactId>camus-api</artifactId>
<version>0.1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.linkedin.camus</groupId>
<artifactId>camus-etl-kafka</artifactId>
<version>0.1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-core</artifactId>
<version>1.0.3</version>
</dependency>
</dependencies>
A file called camus.properties that is located in the jar file for the
custom loader controls the Camus loading process. Either copy this file
from the camus-example project or use the version included in this topic's
project source code. If the file from camus-example is used, some entries
need to be modified to use the custom loader.
In this case, the data is assumed to be JSON formatted. A timestamp for the
event is assumed to be in the ts field as a number of milliseconds since the
Unix epoch. This is extracted and the parsed JSON returned along with the
timestamp in a CamusWrapper , which is the class Camus uses to move data
around: