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) |
Modifier and Type | Method and Description |
---|---|
ShardSpec |
SegmentIdentifier.getShardSpec() |
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) |
Modifier and Type | Class and Description |
---|---|
class |
HashBasedNumberedShardSpec |
class |
LinearShardSpec |
class |
NoneShardSpec |
class |
NumberedShardSpec |
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–2017. All rights reserved.