Examples of generatePartitionedPath()


Examples of com.linkedin.camus.etl.kafka.partitioner.DefaultPartitioner.generatePartitionedPath()

        Job testJob = new Job(new Configuration());

        DefaultPartitioner testPartitioner = new DefaultPartitioner();
        testPartitioner.setConf(testConfiguration);

        String actualResult = testPartitioner.generatePartitionedPath(testJob, "testTopic", "1406777693000");
        String expectedResult = "testTopic/hourly/2014/07/30/20";
       
        assertTrue(actualResult.equals(expectedResult));
       
        actualResult = testPartitioner.generateFileName(testJob, "testTopic", "testBrokerId", 123, 100, 500, "1406777693000");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.