io.druid.indexer.partitions

Class AbstractPartitionsSpec

java.lang.Object

io.druid.indexer.partitions.AbstractPartitionsSpec

All Implemented Interfaces:

PartitionsSpec

Direct Known Subclasses:

HashedPartitionsSpec, SingleDimensionPartitionsSpec

public abstract class AbstractPartitionsSpec
extends Object
implements PartitionsSpec

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
long	getMaxPartitionSize()
int	getNumShards()
long	getTargetPartitionSize()
boolean	isAssumeGrouped()
boolean	isDeterminingPartitions()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.druid.indexer.partitions.PartitionsSpec

getPartitionJob

Constructor Detail

AbstractPartitionsSpec

public AbstractPartitionsSpec(Long targetPartitionSize,
                      Long maxPartitionSize,
                      Boolean assumeGrouped,
                      Integer numShards)

Method Detail

getTargetPartitionSize

public long getTargetPartitionSize()

Specified by:

getTargetPartitionSize in interface PartitionsSpec

getMaxPartitionSize

public long getMaxPartitionSize()

Specified by:

getMaxPartitionSize in interface PartitionsSpec

isAssumeGrouped

public boolean isAssumeGrouped()

Specified by:

isAssumeGrouped in interface PartitionsSpec

isDeterminingPartitions

public boolean isDeterminingPartitions()

Specified by:

isDeterminingPartitions in interface PartitionsSpec

getNumShards

public int getNumShards()

Specified by:

getNumShards in interface PartitionsSpec