File tree Expand file tree Collapse file tree 1 file changed +2
-5
lines changed
beam/tools/src/main/java/cz/o2/proxima/beam/tools/groovy Expand file tree Collapse file tree 1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change 1919import static cz .o2 .proxima .beam .util .RunnerUtils .createJarFromDynamicClasses ;
2020import static cz .o2 .proxima .beam .util .RunnerUtils .registerToPipeline ;
2121
22- import com .google .api .client .util .Lists ;
2322import com .google .auto .service .AutoService ;
2423import cz .o2 .proxima .beam .core .BeamDataOperator ;
2524import cz .o2 .proxima .beam .core .ProximaPipelineOptions ;
3332import cz .o2 .proxima .core .util .ExceptionUtils ;
3433import cz .o2 .proxima .core .util .Pair ;
3534import cz .o2 .proxima .internal .com .google .common .annotations .VisibleForTesting ;
36- import cz .o2 .proxima .internal .com .google .common .base .MoreObjects ;
3735import cz .o2 .proxima .internal .com .google .common .base .Preconditions ;
3836import cz .o2 .proxima .tools .groovy .Stream ;
3937import cz .o2 .proxima .tools .groovy .StreamProvider ;
@@ -223,9 +221,8 @@ Factory<Pipeline> getJarRegisteringPipelineFactory() {
223221 return () -> {
224222 PipelineOptions opts = factory .get ();
225223 ExperimentalOptions experimentOpts = opts .as (ExperimentalOptions .class );
226- ArrayList <String > experiments =
227- Lists .newArrayList (
228- MoreObjects .firstNonNull (experimentOpts .getExperiments (), new ArrayList <>()));
224+ List <String > experiments =
225+ Optional .ofNullable (experimentOpts .getExperiments ()).orElseGet (ArrayList ::new );
229226 experiments .add ("use_deprecated_read" );
230227 experimentOpts .setExperiments (experiments );
231228 Pipeline pipeline = createPipeline .apply (opts );
You can’t perform that action at this time.
0 commit comments