File tree Expand file tree Collapse file tree 2 files changed +2
-13
lines changed
examples/src/main/java/com/google/cloud/dataflow/examples/complete
sdk/src/main/java/com/google/cloud/dataflow/sdk/options Expand file tree Collapse file tree 2 files changed +2
-13
lines changed Original file line number Diff line number Diff line change 68
68
*
69
69
* <p>The default input is {@code gs://dataflow-samples/wikipedia_edits/*.json} and can be
70
70
* overridden with {@code --input}.
71
- *
72
- * <p>The input for this example is large enough that it's a good place to enable (experimental)
73
- * autoscaling:
74
- * <pre>{@code
75
- * --autoscalingAlgorithm=BASIC
76
- * --maxNumWorkers=20
77
- * }
78
- * </pre>
79
- * This will automatically scale the number of workers up over time until the job completes.
80
71
*/
81
72
public class TopWikipediaSessions {
82
73
private static final String EXPORTED_WIKI_TABLE = "gs://dataflow-samples/wikipedia_edits/*.json" ;
Original file line number Diff line number Diff line change @@ -45,7 +45,6 @@ public interface DataflowPipelineWorkerPoolOptions extends PipelineOptions {
45
45
/**
46
46
* Type of autoscaling algorithm to use.
47
47
*/
48
- @ Experimental (Experimental .Kind .AUTOSCALING )
49
48
enum AutoscalingAlgorithmType {
50
49
/** Use numWorkers machines. Do not autoscale the worker pool. */
51
50
NONE ("AUTOSCALING_ALGORITHM_NONE" ),
@@ -69,7 +68,7 @@ public String getAlgorithm() {
69
68
}
70
69
71
70
/**
72
- * [Experimental] The autoscaling algorithm to use for the workerpool.
71
+ * The autoscaling algorithm to use for the workerpool.
73
72
*
74
73
* <ul>
75
74
* <li>NONE: does not change the size of the worker pool.</li>
@@ -78,12 +77,11 @@ public String getAlgorithm() {
78
77
* </li>
79
78
* </ul>
80
79
*/
81
- @ Description ("[Experimental] The autoscaling algorithm to use for the workerpool. "
80
+ @ Description ("The autoscaling algorithm to use for the workerpool. "
82
81
+ "NONE: does not change the size of the worker pool. "
83
82
+ "BASIC (deprecated): autoscale the worker pool size up to maxNumWorkers until the job "
84
83
+ "completes. "
85
84
+ "THROUGHPUT_BASED: autoscale the workerpool based on throughput (up to maxNumWorkers)." )
86
- @ Experimental (Experimental .Kind .AUTOSCALING )
87
85
AutoscalingAlgorithmType getAutoscalingAlgorithm ();
88
86
void setAutoscalingAlgorithm (AutoscalingAlgorithmType value );
89
87
You can’t perform that action at this time.
0 commit comments