Skip to content

TableInputSpecSlicer changes to support running on Brokers.#17074

Merged
gianm merged 3 commits intoapache:masterfrom
gianm:msq-tiss-broker
Sep 17, 2024
Merged

TableInputSpecSlicer changes to support running on Brokers.#17074
gianm merged 3 commits intoapache:masterfrom
gianm:msq-tiss-broker

Conversation

@gianm
Copy link
Copy Markdown
Contributor

@gianm gianm commented Sep 16, 2024

Changes:

  1. Rename TableInputSpecSlicer to IndexerTableInputSpecSlicer, in anticipation
    of a new implementation being added for controllers running on Brokers.

  2. Allow the context to use the WorkerManager to build the TableInputSpecSlicer,
    in anticipation of Brokers wanting to use this to assign segments to servers
    that are already serving those segments.

  3. Remove unused DataSegmentTimelineView interface.

  4. Add additional javadoc to DataSegmentProvider.

Changes:

1) Rename TableInputSpecSlicer to IndexerTableInputSpecSlicer, in anticipation
   of a new implementation being added for controllers running on Brokers.

2) Allow the context to use the WorkerManager to build the TableInputSpecSlicer,
   in anticipation of Brokers wanting to use this to assign segments to servers
   that are already serving those segments.

3) Remove unused DataSegmentTimelineView interface.

4) Add additional javadoc to DataSegmentProvider.
@github-actions github-actions Bot added Area - Batch Ingestion Area - MSQ For multi stage queries - https://github.com/apache/druid/issues/12262 labels Sep 16, 2024
* Provides an {@link InputSpecSlicer} that slices {@link TableInputSpec} into {@link SegmentsInputSlice}.
*/
InputSpecSlicer newTableInputSpecSlicer();
InputSpecSlicer newTableInputSpecSlicer(WorkerManager workerManager);

Check notice

Code scanning / CodeQL

Useless parameter

The parameter 'workerManager' is never used.
@gianm gianm merged commit 8af9b47 into apache:master Sep 17, 2024
@gianm gianm deleted the msq-tiss-broker branch September 17, 2024 10:51
pranavbhole pushed a commit to pranavbhole/druid that referenced this pull request Sep 17, 2024
…7074)

* TableInputSpecSlicer changes to support running on Brokers.

Changes:

1) Rename TableInputSpecSlicer to IndexerTableInputSpecSlicer, in anticipation
   of a new implementation being added for controllers running on Brokers.

2) Allow the context to use the WorkerManager to build the TableInputSpecSlicer,
   in anticipation of Brokers wanting to use this to assign segments to servers
   that are already serving those segments.

3) Remove unused DataSegmentTimelineView interface.

4) Add additional javadoc to DataSegmentProvider.

* Style.
@kfaraz kfaraz added this to the 31.0.0 milestone Oct 4, 2024
kfaraz pushed a commit to kfaraz/druid that referenced this pull request Oct 4, 2024
…7074)

* TableInputSpecSlicer changes to support running on Brokers.

Changes:

1) Rename TableInputSpecSlicer to IndexerTableInputSpecSlicer, in anticipation
   of a new implementation being added for controllers running on Brokers.

2) Allow the context to use the WorkerManager to build the TableInputSpecSlicer,
   in anticipation of Brokers wanting to use this to assign segments to servers
   that are already serving those segments.

3) Remove unused DataSegmentTimelineView interface.

4) Add additional javadoc to DataSegmentProvider.

* Style.
kfaraz added a commit that referenced this pull request Oct 4, 2024
…) (#17074) (#17076) (#17077) (#17193) (#17243)

Backport the following patches for a clean backport of Dart changes
1. Add "targetPartitionsPerWorker" setting for MSQ. (#17048)
2. MSQ: Improved worker cancellation. (#17046)
3. Add "includeAllCounters()" to WorkerContext. (#17047)
4. MSQ: Include worker context maps in WorkOrders. (#17076)
5. TableInputSpecSlicer changes to support running on Brokers. (#17074)
6. Fix call to MemoryIntrospector in IndexerControllerContext. (#17066)
7. MSQ: Add QueryKitSpec to encapsulate QueryKit params. (#17077)
8. MSQ: Use task context flag useConcurrentLocks to determine task lock type (#17193)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Area - Batch Ingestion Area - MSQ For multi stage queries - https://github.com/apache/druid/issues/12262

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants