| Package | Description |
|---|---|
| com.google.api.services.dataflow.model |
| Modifier and Type | Method and Description |
|---|---|
StreamingScalingReport |
StreamingScalingReport.clone() |
StreamingScalingReport |
WorkerMessage.getStreamingScalingReport()
Contains per-user worker telemetry used in streaming autoscaling.
|
StreamingScalingReport |
StreamingScalingReport.set(String fieldName,
Object value) |
StreamingScalingReport |
StreamingScalingReport.setActiveBundleCount(Integer activeBundleCount)
Current acive bundle count.
|
StreamingScalingReport |
StreamingScalingReport.setActiveThreadCount(Integer activeThreadCount)
Current acive thread count.
|
StreamingScalingReport |
StreamingScalingReport.setMaximumBundleCount(Integer maximumBundleCount)
Maximum bundle count limit.
|
StreamingScalingReport |
StreamingScalingReport.setMaximumBytesCount(Integer maximumBytesCount)
Maximum bytes count limit.
|
StreamingScalingReport |
StreamingScalingReport.setMaximumThreadCount(Integer maximumThreadCount)
Maximum thread count limit.
|
StreamingScalingReport |
StreamingScalingReport.setOutstandingBytesCount(Integer outstandingBytesCount)
Current outstanding bytes count.
|
| Modifier and Type | Method and Description |
|---|---|
WorkerMessage |
WorkerMessage.setStreamingScalingReport(StreamingScalingReport streamingScalingReport)
Contains per-user worker telemetry used in streaming autoscaling.
|
Copyright © 2011–2023 Google. All rights reserved.