io.druid.indexer.partitions

Class HashedPartitionsSpec

java.lang.Object

io.druid.indexer.partitions.AbstractPartitionsSpec

io.druid.indexer.partitions.HashedPartitionsSpec

All Implemented Interfaces:

PartitionsSpec

Direct Known Subclasses:

RandomPartitionsSpec

public class HashedPartitionsSpec
extends AbstractPartitionsSpec

Constructor Summary

Constructors

Constructor and Description
HashedPartitionsSpec(Long targetPartitionSize, Long maxPartitionSize, Boolean assumeGrouped, Integer numShards)

Method Summary

Methods

Modifier and Type	Method and Description
Jobby	getPartitionJob(HadoopDruidIndexerConfig config)
static HashedPartitionsSpec	makeDefaultHashedPartitionsSpec()

Methods inherited from class io.druid.indexer.partitions.AbstractPartitionsSpec

getMaxPartitionSize, getNumShards, getTargetPartitionSize, isAssumeGrouped, isDeterminingPartitions

Methods inherited from class java.lang.Object

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

Constructor Detail

HashedPartitionsSpec

public HashedPartitionsSpec(@Nullable
                    Long targetPartitionSize,
                    @Nullable
                    Long maxPartitionSize,
                    @Nullable
                    Boolean assumeGrouped,
                    @Nullable
                    Integer numShards)

Method Detail

makeDefaultHashedPartitionsSpec

public static HashedPartitionsSpec makeDefaultHashedPartitionsSpec()

getPartitionJob

public Jobby getPartitionJob(HadoopDruidIndexerConfig config)