Modifier and Type | Method and Description |
---|---|
SegmentWriteOutMediumFactory |
MergeTaskBase.getSegmentWriteOutMediumFactory() |
SegmentWriteOutMediumFactory |
IndexTask.IndexTuningConfig.getSegmentWriteOutMediumFactory() |
SegmentWriteOutMediumFactory |
ConvertSegmentTask.getSegmentWriteOutMediumFactory() |
Modifier and Type | Method and Description |
---|---|
static ConvertSegmentTask |
ConvertSegmentTask.create(DataSegment segment,
IndexSpec indexSpec,
boolean force,
boolean validate,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context)
Create a task to update the segment specified to the most recent binary version with the specified indexSpec
|
static ConvertSegmentTask |
ConvertSegmentTask.create(String dataSource,
org.joda.time.Interval interval,
IndexSpec indexSpec,
boolean force,
boolean validate,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context)
Create a segment converter task to convert a segment to the most recent version including the specified indexSpec
|
Constructor and Description |
---|
AppendTask(String id,
String dataSource,
List<DataSegment> segments,
List<AggregatorFactory> aggregators,
IndexSpec indexSpec,
Boolean buildV9Directly,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
ConvertSegmentBackwardsCompatibleTask(String id,
String dataSource,
org.joda.time.Interval interval,
DataSegment segment,
IndexSpec indexSpec,
Boolean force,
Boolean validate,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)
Deprecated.
|
HadoopConverterTask(String id,
String dataSource,
org.joda.time.Interval interval,
IndexSpec indexSpec,
boolean force,
Boolean validate,
List<String> hadoopDependencyCoordinates,
URI distributedSuccessCache,
String jobPriority,
String segmentOutputPath,
String classpathPrefix,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
IndexTuningConfig(Integer targetPartitionSize,
Integer maxRowsInMemory,
Long maxTotalRows,
Integer rowFlushBoundary_forBackCompatibility,
Integer numShards,
IndexSpec indexSpec,
Integer maxPendingPersists,
Boolean buildV9Directly,
Boolean forceExtendableShardSpecs,
Boolean forceGuaranteedRollup,
Boolean reportParseExceptions,
Long publishTimeout,
Long pushTimeout,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
MergeTask(String id,
String dataSource,
List<DataSegment> segments,
List<AggregatorFactory> aggregators,
Boolean rollup,
IndexSpec indexSpec,
Boolean buildV9Directly,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
MergeTaskBase(String id,
String dataSource,
List<DataSegment> segments,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
SameIntervalMergeTask(String id,
String dataSource,
org.joda.time.Interval interval,
List<AggregatorFactory> aggregators,
Boolean rollup,
IndexSpec indexSpec,
Boolean buildV9Directly,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
SubTask(String groupId,
DataSegment segment,
IndexSpec indexSpec,
Boolean force,
Boolean validate,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)
Deprecated.
|
SubTask(String groupId,
DataSegment segment,
IndexSpec indexSpec,
Boolean force,
Boolean validate,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
SegmentWriteOutMediumFactory |
KafkaTuningConfig.getSegmentWriteOutMediumFactory() |
Constructor and Description |
---|
KafkaTuningConfig(Integer maxRowsInMemory,
Integer maxRowsPerSegment,
org.joda.time.Period intermediatePersistPeriod,
File basePersistDirectory,
Integer maxPendingPersists,
IndexSpec indexSpec,
Boolean buildV9Directly,
Boolean reportParseExceptions,
Long handoffConditionTimeout,
Boolean resetOffsetAutomatically,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
Constructor and Description |
---|
KafkaSupervisorTuningConfig(Integer maxRowsInMemory,
Integer maxRowsPerSegment,
org.joda.time.Period intermediatePersistPeriod,
File basePersistDirectory,
Integer maxPendingPersists,
IndexSpec indexSpec,
Boolean buildV9Directly,
Boolean reportParseExceptions,
Long handoffConditionTimeout,
Boolean resetOffsetAutomatically,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Integer workerThreads,
Integer chatThreads,
Long chatRetries,
org.joda.time.Period httpTimeout,
org.joda.time.Period shutdownTimeout,
org.joda.time.Period offsetFetchPeriod) |
Modifier and Type | Method and Description |
---|---|
File |
IndexMergerV9.append(List<IndexableAdapter> indexes,
AggregatorFactory[] aggregators,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMerger.append(List<IndexableAdapter> indexes,
AggregatorFactory[] aggregators,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMergerV9.convert(File inDir,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMerger.convert(File inDir,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
boolean |
IndexIO.convertSegment(File toConvert,
File converted,
IndexSpec indexSpec,
boolean forceIfCurrent,
boolean validate,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMergerV9.mergeQueryableIndex(List<QueryableIndex> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMergerV9.mergeQueryableIndex(List<QueryableIndex> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMergerV9.persist(IncrementalIndex index,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMerger.persist(IncrementalIndex index,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMergerV9.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMerger.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMergerV9.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMerger.persist(IncrementalIndex index,
org.joda.time.Interval dataInterval,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)
This is *not* thread-safe and havok will ensue if this is called and writes are still occurring
on the IncrementalIndex object.
|
Constructor and Description |
---|
IndexIO(com.fasterxml.jackson.databind.ObjectMapper mapper,
SegmentWriteOutMediumFactory defaultSegmentWriteOutMediumFactory,
ColumnConfig columnConfig) |
IndexMergerV9(com.fasterxml.jackson.databind.ObjectMapper mapper,
IndexIO indexIO,
SegmentWriteOutMediumFactory defaultSegmentWriteOutMediumFactory) |
Modifier and Type | Method and Description |
---|---|
SegmentWriteOutMediumFactory |
RealtimeTuningConfig.getSegmentWriteOutMediumFactory() |
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 |
---|---|
SegmentWriteOutMediumFactory |
AppenderatorConfig.getSegmentWriteOutMediumFactory() |
Modifier and Type | Class and Description |
---|---|
class |
OffHeapMemorySegmentWriteOutMediumFactory |
class |
TmpFileSegmentWriteOutMediumFactory |
Modifier and Type | Method and Description |
---|---|
static Set<SegmentWriteOutMediumFactory> |
SegmentWriteOutMediumFactory.builtInFactories() |
Copyright © 2011–2018. All rights reserved.