Modifier and Type | Method and Description |
---|---|
ShardSpec |
HadoopyShardSpec.getActualSpec() |
Constructor and Description |
---|
HadoopyShardSpec(ShardSpec actualSpec,
int shardNum) |
Modifier and Type | Method and Description |
---|---|
static <T> Set<T> |
DimFilterUtils.filterShards(DimFilter dimFilter,
Iterable<T> input,
com.google.common.base.Function<T,ShardSpec> converter)
Filter the given iterable of objects by removing any object whose ShardSpec, obtained from the converter function,
does not fit in the RangeSet of the dimFilter
DimFilter.getDimensionRangeSet(String) . |
static <T> Set<T> |
DimFilterUtils.filterShards(DimFilter dimFilter,
Iterable<T> input,
com.google.common.base.Function<T,ShardSpec> converter,
Map<String,com.google.common.base.Optional<com.google.common.collect.RangeSet<String>>> dimensionRangeCache)
Filter the given iterable of objects by removing any object whose ShardSpec, obtained from the converter function,
does not fit in the RangeSet of the dimFilter
DimFilter.getDimensionRangeSet(String) . |
Modifier and Type | Method and Description |
---|---|
ShardSpec |
RealtimeTuningConfig.getShardSpec() |
Constructor and Description |
---|
RealtimeTuningConfig(Integer maxRowsInMemory,
org.joda.time.Period intermediatePersistPeriod,
org.joda.time.Period windowPeriod,
File basePersistDirectory,
VersioningPolicy versioningPolicy,
RejectionPolicyFactory rejectionPolicyFactory,
Integer maxPendingPersists,
ShardSpec shardSpec,
IndexSpec indexSpec,
Boolean buildV9Directly,
int persistThreadPriority,
int mergeThreadPriority,
Boolean reportParseExceptions,
Long handoffConditionTimeout,
Long alertTimeout,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
Modifier and Type | Method and Description |
---|---|
ShardSpec |
SegmentIdentifier.getShardSpec() |
Modifier and Type | Method and Description |
---|---|
static String |
Appenderators.getSequenceName(org.joda.time.Interval interval,
String version,
ShardSpec shardSpec) |
Constructor and Description |
---|
SegmentIdentifier(String dataSource,
org.joda.time.Interval interval,
String version,
ShardSpec shardSpec) |
Constructor and Description |
---|
Sink(org.joda.time.Interval interval,
DataSchema schema,
ShardSpec shardSpec,
String version,
int maxRowsInMemory,
boolean reportParseExceptions) |
Sink(org.joda.time.Interval interval,
DataSchema schema,
ShardSpec shardSpec,
String version,
int maxRowsInMemory,
boolean reportParseExceptions,
List<FireHydrant> hydrants) |
Modifier and Type | Method and Description |
---|---|
ShardSpec |
DataSegment.getShardSpec() |
Modifier and Type | Method and Description |
---|---|
static String |
DataSegment.makeDataSegmentIdentifier(String dataSource,
org.joda.time.DateTime start,
org.joda.time.DateTime end,
String version,
ShardSpec shardSpec) |
DataSegment.Builder |
DataSegment.Builder.shardSpec(ShardSpec shardSpec) |
Constructor and Description |
---|
DataSegment(String dataSource,
org.joda.time.Interval interval,
String version,
Map<String,Object> loadSpec,
List<String> dimensions,
List<String> metrics,
ShardSpec shardSpec,
Integer binaryVersion,
long size) |
DataSegment(String dataSource,
org.joda.time.Interval interval,
String version,
Map<String,Object> loadSpec,
List<String> dimensions,
List<String> metrics,
ShardSpec shardSpec,
Integer binaryVersion,
long size,
DataSegment.PruneLoadSpecHolder pruneLoadSpecHolder) |
Modifier and Type | Class and Description |
---|---|
class |
HashBasedNumberedShardSpec |
class |
LinearShardSpec
An extendable linear shard spec.
|
class |
NoneShardSpec |
class |
NumberedShardSpec
An extendable linear shard spec containing the information of core partitions.
|
class |
SingleDimensionShardSpec
Class uses getters/setters to work around http://jira.codehaus.org/browse/MSHADE-92
Adjust to JsonCreator and final fields when resolved.
|
Modifier and Type | Method and Description |
---|---|
ShardSpec |
ShardSpecLookup.getShardSpec(long timestamp,
InputRow row) |
Modifier and Type | Method and Description |
---|---|
ShardSpecLookup |
ShardSpec.getLookup(List<ShardSpec> shardSpecs) |
ShardSpecLookup |
NoneShardSpec.getLookup(List<ShardSpec> shardSpecs) |
ShardSpecLookup |
SingleDimensionShardSpec.getLookup(List<ShardSpec> shardSpecs) |
ShardSpecLookup |
NumberedShardSpec.getLookup(List<ShardSpec> shardSpecs) |
ShardSpecLookup |
LinearShardSpec.getLookup(List<ShardSpec> shardSpecs) |
ShardSpecLookup |
HashBasedNumberedShardSpec.getLookup(List<ShardSpec> shardSpecs) |
Copyright © 2011–2018. All rights reserved.