This repository has been archived by the owner on Oct 30, 2020. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 457
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
committing change to partitioner as well as other changes needed to b…
…uild
- Loading branch information
kgoodhop
committed
Feb 1, 2014
1 parent
8eb5618
commit 637a92f
Showing
15 changed files
with
1,524 additions
and
62 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
69 changes: 69 additions & 0 deletions
69
camus-etl-kafka/src/main/java/com/linkedin/camus/events/EventHeader.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,69 @@ | ||
| /** | ||
| * Autogenerated by Avro | ||
| * | ||
| * DO NOT EDIT DIRECTLY | ||
| */ | ||
| package com.linkedin.camus.events; | ||
|
|
||
| @SuppressWarnings("all") | ||
| /** The basic header for every tracking event. */ | ||
| public class EventHeader extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { | ||
| public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema | ||
| .parse("{\"type\":\"record\",\"name\":\"EventHeader\",\"namespace\":\"com.linkedin.events\",\"fields\":[{\"name\":\"memberId\",\"type\":\"int\",\"doc\":\"The member id of the user initiating the action\"},{\"name\":\"time\",\"type\":\"long\",\"doc\":\"The time of the event\"},{\"name\":\"server\",\"type\":\"string\",\"doc\":\"The name of the server\"},{\"name\":\"service\",\"type\":\"string\",\"doc\":\"The name of the service\"},{\"name\":\"guid\",\"type\":{\"type\":\"fixed\",\"name\":\"Guid\",\"size\":16},\"doc\":\"A unique identifier for the message\"}]}"); | ||
| /** The member id of the user initiating the action */ | ||
| public int memberId; | ||
| /** The time of the event */ | ||
| public long time; | ||
| /** The name of the server */ | ||
| public java.lang.CharSequence server; | ||
| /** The name of the service */ | ||
| public java.lang.CharSequence service; | ||
| /** A unique identifier for the message */ | ||
| public com.linkedin.camus.events.Guid guid; | ||
|
|
||
| public org.apache.avro.Schema getSchema() { | ||
| return SCHEMA$; | ||
| } | ||
|
|
||
| // Used by DatumWriter. Applications should not call. | ||
| public java.lang.Object get(int field$) { | ||
| switch (field$) { | ||
| case 0: | ||
| return memberId; | ||
| case 1: | ||
| return time; | ||
| case 2: | ||
| return server; | ||
| case 3: | ||
| return service; | ||
| case 4: | ||
| return guid; | ||
| default: | ||
| throw new org.apache.avro.AvroRuntimeException("Bad index"); | ||
| } | ||
| } | ||
|
|
||
| // Used by DatumReader. Applications should not call. | ||
| @SuppressWarnings(value = "unchecked") | ||
| public void put(int field$, java.lang.Object value$) { | ||
| switch (field$) { | ||
| case 0: | ||
| memberId = (java.lang.Integer) value$; | ||
| break; | ||
| case 1: | ||
| time = (java.lang.Long) value$; | ||
| break; | ||
| case 2: | ||
| server = (java.lang.CharSequence) value$; | ||
| break; | ||
| case 3: | ||
| service = (java.lang.CharSequence) value$; | ||
| break; | ||
| case 4: | ||
| guid = (com.linkedin.camus.events.Guid) value$; | ||
| break; | ||
| default: | ||
| throw new org.apache.avro.AvroRuntimeException("Bad index"); | ||
| } | ||
| } | ||
| } |
11 changes: 11 additions & 0 deletions
11
camus-etl-kafka/src/main/java/com/linkedin/camus/events/Guid.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,11 @@ | ||
| /** | ||
| * Autogenerated by Avro | ||
| * | ||
| * DO NOT EDIT DIRECTLY | ||
| */ | ||
| package com.linkedin.camus.events; | ||
|
|
||
| @SuppressWarnings("all") | ||
| @org.apache.avro.specific.FixedSize(16) | ||
| public class Guid extends org.apache.avro.specific.SpecificFixed { | ||
| } |
78 changes: 78 additions & 0 deletions
78
camus-etl-kafka/src/main/java/com/linkedin/camus/events/TrackingMonitoringEvent.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,78 @@ | ||
| /** | ||
| * Autogenerated by Avro | ||
| * | ||
| * DO NOT EDIT DIRECTLY | ||
| */ | ||
| package com.linkedin.camus.events; | ||
|
|
||
| @SuppressWarnings("all") | ||
| /** An event to monitor the tracking system itself */ | ||
| public class TrackingMonitoringEvent extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord { | ||
| public static final org.apache.avro.Schema SCHEMA$ = org.apache.avro.Schema | ||
| .parse("{\"type\":\"record\",\"name\":\"TrackingMonitoringEvent\",\"namespace\":\"com.linkedin.events\",\"fields\":[{\"name\":\"header\",\"type\":{\"type\":\"record\",\"name\":\"EventHeader\",\"fields\":[{\"name\":\"memberId\",\"type\":\"int\",\"doc\":\"The member id of the user initiating the action\"},{\"name\":\"time\",\"type\":\"long\",\"doc\":\"The time of the event\"},{\"name\":\"server\",\"type\":\"string\",\"doc\":\"The name of the server\"},{\"name\":\"service\",\"type\":\"string\",\"doc\":\"The name of the service\"},{\"name\":\"guid\",\"type\":{\"type\":\"fixed\",\"name\":\"Guid\",\"size\":16},\"doc\":\"A unique identifier for the message\"}]}},{\"name\":\"tier\",\"type\":\"string\",\"doc\":\"A name for the tier of servers to which this event belongs (client, broker, etc)\"},{\"name\":\"eventType\",\"type\":\"string\",\"doc\":\"The event type being monitored\"},{\"name\":\"count\",\"type\":\"long\",\"doc\":\"The number of events sent in this time period\"},{\"name\":\"beginTimestamp\",\"type\":\"long\",\"doc\":\"The timestamp at which this count began\"},{\"name\":\"endTimestamp\",\"type\":\"long\",\"doc\":\"The timestamp at which this count ended\"}]}"); | ||
| public com.linkedin.camus.events.EventHeader header; | ||
| /** | ||
| * A name for the tier of servers to which this event belongs (client, | ||
| * broker, etc) | ||
| */ | ||
| public java.lang.CharSequence tier; | ||
| /** The event type being monitored */ | ||
| public java.lang.CharSequence eventType; | ||
| /** The number of events sent in this time period */ | ||
| public long count; | ||
| /** The timestamp at which this count began */ | ||
| public long beginTimestamp; | ||
| /** The timestamp at which this count ended */ | ||
| public long endTimestamp; | ||
|
|
||
| public org.apache.avro.Schema getSchema() { | ||
| return SCHEMA$; | ||
| } | ||
|
|
||
| // Used by DatumWriter. Applications should not call. | ||
| public java.lang.Object get(int field$) { | ||
| switch (field$) { | ||
| case 0: | ||
| return header; | ||
| case 1: | ||
| return tier; | ||
| case 2: | ||
| return eventType; | ||
| case 3: | ||
| return count; | ||
| case 4: | ||
| return beginTimestamp; | ||
| case 5: | ||
| return endTimestamp; | ||
| default: | ||
| throw new org.apache.avro.AvroRuntimeException("Bad index"); | ||
| } | ||
| } | ||
|
|
||
| // Used by DatumReader. Applications should not call. | ||
| @SuppressWarnings(value = "unchecked") | ||
| public void put(int field$, java.lang.Object value$) { | ||
| switch (field$) { | ||
| case 0: | ||
| header = (com.linkedin.camus.events.EventHeader) value$; | ||
| break; | ||
| case 1: | ||
| tier = (java.lang.CharSequence) value$; | ||
| break; | ||
| case 2: | ||
| eventType = (java.lang.CharSequence) value$; | ||
| break; | ||
| case 3: | ||
| count = (java.lang.Long) value$; | ||
| break; | ||
| case 4: | ||
| beginTimestamp = (java.lang.Long) value$; | ||
| break; | ||
| case 5: | ||
| endTimestamp = (java.lang.Long) value$; | ||
| break; | ||
| default: | ||
| throw new org.apache.avro.AvroRuntimeException("Bad index"); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.