Package co.gridport.kafka.hadoop

Examples of co.gridport.kafka.hadoop.KafkaInputFormat


        //conf.set("kafka.watermark.reset", "earliest");
        conf.set("input.format", "json");

        JobContext dummyJobContext  = new Job(conf);

        KafkaInputFormat realInputFormat = new KafkaInputFormat();
        List<InputSplit> splits = realInputFormat.getSplits(dummyJobContext);

        Collection<Callable<String>> tasks = new ArrayList<Callable<String>>();
        for(InputSplit split: splits)
        {
            tasks.add(new MockMapTask(split, conf));
View Full Code Here

TOP

Related Classes of co.gridport.kafka.hadoop.KafkaInputFormat

Copyright © 2018 www.massapicom. 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.