io.druid.indexer

Class DetermineHashedPartitionsJob

java.lang.Object

io.druid.indexer.DetermineHashedPartitionsJob

All Implemented Interfaces:

Jobby

public class DetermineHashedPartitionsJob
extends Object
implements Jobby

Determines appropriate ShardSpecs for a job by determining approximate cardinality of data set using HyperLogLog

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DetermineHashedPartitionsJob.DetermineCardinalityMapper
static class	DetermineHashedPartitionsJob.DetermineCardinalityReducer
static class	DetermineHashedPartitionsJob.DetermineHashedPartitionsPartitioner

Constructor Summary

Constructors

Constructor and Description
DetermineHashedPartitionsJob(HadoopDruidIndexerConfig config)

Method Summary

Modifier and Type	Method and Description
boolean	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DetermineHashedPartitionsJob

public DetermineHashedPartitionsJob(HadoopDruidIndexerConfig config)

Method Detail

run

public boolean run()

Specified by:

run in interface Jobby