io.druid.indexer.partitions

Class HashedPartitionsSpec

java.lang.Object

io.druid.indexer.partitions.AbstractPartitionsSpec

io.druid.indexer.partitions.HashedPartitionsSpec

All Implemented Interfaces:

PartitionsSpec

public class HashedPartitionsSpec
extends AbstractPartitionsSpec

Constructor Summary

Constructors

Constructor and Description
HashedPartitionsSpec(Long targetPartitionSize, Long maxPartitionSize, Boolean assumeGrouped, Integer numShards, List<String> partitionDimensions)

Method Summary

Modifier and Type	Method and Description
List<String>	getPartitionDimensions()
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,
                            @Nullable
                            List<String> partitionDimensions)

Method Detail

makeDefaultHashedPartitionsSpec

public static HashedPartitionsSpec makeDefaultHashedPartitionsSpec()

getPartitionJob

public Jobby getPartitionJob(HadoopDruidIndexerConfig config)

getPartitionDimensions

public List<String> getPartitionDimensions()