arunpandianp commented on code in PR #38814:
URL: https://github.com/apache/beam/pull/38814#discussion_r3371046031
##########
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java:
##########
@@ -162,6 +167,33 @@ public class StreamingModeExecutionContext extends
DataflowExecutionContext<Step
private @Nullable WorkExecutor workExecutor;
private boolean finishKeyCalled = false;
+ @SuppressWarnings("UnusedVariable")
+ private @Nullable BoundedQueueExecutor workQueueExecutor;
+
+ @SuppressWarnings("UnusedVariable")
+ private @Nullable BoundedQueueExecutorWorkHandle budgetHandle;
+
+ private final HotKeyLogger hotKeyLogger;
+ private boolean hotKeyLoggingEnabled = false;
+ private final String stepName;
+ private @Nullable Coder<?> keyCoder;
+
+ // Key switch listener to delegate MDC logging context and thread name
updates
+ public interface KeySwitchListener {
+ void onKeySwitch(Work oldWork, Work newWork);
Review Comment:
updated to KeyTransitionListener
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
