chenboat commented on a change in pull request #5314:
URL: https://github.com/apache/incubator-pinot/pull/5314#discussion_r418808964
##########
File path:
pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/SplitSegmentCommitter.java
##########
@@ -35,16 +38,34 @@
private final ServerSegmentCompletionProtocolHandler _protocolHandler;
private final IndexLoadingConfig _indexLoadingConfig;
private final SegmentUploader _segmentUploader;
+ // The default segment location uri str, could be null.
+ private final String _defaultSegmentLocation;
private final Logger _segmentLogger;
public SplitSegmentCommitter(Logger segmentLogger,
ServerSegmentCompletionProtocolHandler protocolHandler,
IndexLoadingConfig indexLoadingConfig,
SegmentCompletionProtocol.Request.Params params, SegmentUploader
segmentUploader) {
+ this(segmentLogger, protocolHandler, indexLoadingConfig, params,
segmentUploader, null);
+ }
+
+ /**
+ *
+ * @param segmentLogger
+ * @param protocolHandler
+ * @param indexLoadingConfig
+ * @param params
+ * @param segmentUploader
+ * @param defaultSegmentLocation The default segment location uri str, could
be null.
+ */
+ public SplitSegmentCommitter(Logger segmentLogger,
ServerSegmentCompletionProtocolHandler protocolHandler,
+ IndexLoadingConfig indexLoadingConfig,
SegmentCompletionProtocol.Request.Params params, SegmentUploader
segmentUploader,
+ String defaultSegmentLocation) {
Review comment:
Will send out the config change proposal. Replace indexLoadingConfig
with tableConfig. Note that isEnableSplitCommitEndWithMetadata in
indexLoadingConfig is a server instance level config. TableConfig does not have
this field -- so I add a new boolean flag to the factory creation method. This
flag can be removed if no other is using the deprecated
_protocolHandler.segmentCommitEnd() anymore.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
