Package | Description |
---|---|
io.druid.indexing.common.actions | |
io.druid.indexing.kafka | |
io.druid.indexing.overlord | |
io.druid.metadata |
Modifier and Type | Method and Description |
---|---|
DataSourceMetadata |
SegmentTransactionalInsertAction.getEndMetadata() |
DataSourceMetadata |
SegmentTransactionalInsertAction.getStartMetadata() |
Constructor and Description |
---|
SegmentTransactionalInsertAction(Set<DataSegment> segments,
DataSourceMetadata startMetadata,
DataSourceMetadata endMetadata) |
Modifier and Type | Class and Description |
---|---|
class |
KafkaDataSourceMetadata |
Modifier and Type | Method and Description |
---|---|
DataSourceMetadata |
KafkaDataSourceMetadata.plus(DataSourceMetadata other) |
Modifier and Type | Method and Description |
---|---|
boolean |
KafkaDataSourceMetadata.matches(DataSourceMetadata other) |
DataSourceMetadata |
KafkaDataSourceMetadata.plus(DataSourceMetadata other) |
Modifier and Type | Class and Description |
---|---|
class |
ObjectMetadata |
Modifier and Type | Method and Description |
---|---|
DataSourceMetadata |
IndexerMetadataStorageCoordinator.getDataSourceMetadata(String dataSource) |
DataSourceMetadata |
ObjectMetadata.plus(DataSourceMetadata other) |
DataSourceMetadata |
DataSourceMetadata.plus(DataSourceMetadata other)
Returns a copy of this instance with "other" merged in.
|
Modifier and Type | Method and Description |
---|---|
SegmentPublishResult |
IndexerMetadataStorageCoordinator.announceHistoricalSegments(Set<DataSegment> segments,
DataSourceMetadata startMetadata,
DataSourceMetadata endMetadata)
Attempts to insert a set of segments to the metadata storage.
|
boolean |
ObjectMetadata.matches(DataSourceMetadata other) |
boolean |
DataSourceMetadata.matches(DataSourceMetadata other)
Returns true if any information present in this instance matches analogous information from "other" and
so they are conflict-free.
|
DataSourceMetadata |
ObjectMetadata.plus(DataSourceMetadata other) |
DataSourceMetadata |
DataSourceMetadata.plus(DataSourceMetadata other)
Returns a copy of this instance with "other" merged in.
|
Modifier and Type | Method and Description |
---|---|
DataSourceMetadata |
IndexerSQLMetadataStorageCoordinator.getDataSourceMetadata(String dataSource)
Read dataSource metadata.
|
Modifier and Type | Method and Description |
---|---|
SegmentPublishResult |
IndexerSQLMetadataStorageCoordinator.announceHistoricalSegments(Set<DataSegment> segments,
DataSourceMetadata startMetadata,
DataSourceMetadata endMetadata)
Attempts to insert a set of segments to the metadata storage.
|
Copyright © 2011–2016. All rights reserved.