@@ -0,0 +1,1121 @@
+package com.linkedin.camus.etl.kafka.coders;%0A%0A/**%0A * Created by ehrlichja on 7/30/14.%0A */%0A%0Aimport org.apache.hadoop.conf.Configuration;%0Aimport org.apache.hadoop.mapreduce.JobContext;%0Aimport org.apache.hadoop.mapreduce.JobID;%0Aimport org.junit.Test;%0A%0Aimport static org.junit.Assert.assertEquals;%0Aimport static org.junit.Assert.assertThat;%0Aimport static org.junit.Assert.assertTrue;%0A%0A%0Apublic class TestDefaultPartitioner %7B%0A%0A    @Test%0A    public void testGeneratePartitionPath() %7B%0A        // generatePartitionPath() should take a timestamp and return a formatted string by default%0A        Configuration testConfiguration = new Configuration();%0A        JobID testJobID = new JobID();%0A        JobContext testJobContext = new JobContext(testConfiguration, testJobID);%0A%0A        DefaultPartitioner testPartitioner = new DefaultPartitioner();%0A%0A        String actualResult = testPartitioner.generatePartitionedPath(testJobContext, %22testTopic%22, %22testBrokerId%22, 123, %221406777693000%22);%0A        String expectedResult = %22testTopic/hourly/2014-07-30T20:34:53.000-07:00%22;%0A%0A        assertTrue(actualResult.equals(expectedResult));%0A    %7D%0A%0A%7D%0A

test for DefaultPartitioner