assertEquals(messageWithData(new byte[1]),Iterables.get(values,0)); | assertEquals(messageWithData(new byte[1]),values.get(0)); | Iterables.get(values,0) | values.get(0) | beam | 8db19a4645b8588ce9e046637b7619815169bdb1 | org.apache.beam.sdk.fn.data.BeamFnDataTimeBasedBufferingOutboundObserverTest | | | | - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Iterables
| | Uses | True |
assertEquals(BeamFnApi.Elements.newBuilder(messageWithData(new byte[1])).addData(BeamFnApi.Elements.Data.newBuilder().setInstructionId(OUTPUT_LOCATION.getInstructionId()).setTransformId(OUTPUT_LOCATION.getTransformId()).setIsLast(true)).build(),Iterables.get(values,1)); | assertEquals(builder.build(),values.get(1)); | Iterables.get(values,1) | values.get(1) | beam | 8db19a4645b8588ce9e046637b7619815169bdb1 | org.apache.beam.sdk.fn.data.BeamFnDataSizeBasedBufferingOutboundObserverTest | | | | - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Iterables
| | Uses | True |
assertEquals(messageWithData(new byte[51],new byte[49]),Iterables.get(values,0)); | assertEquals(messageWithData(new byte[51],new byte[49]),values.get(0)); | Iterables.get(values,0) | values.get(0) | beam | 8db19a4645b8588ce9e046637b7619815169bdb1 | org.apache.beam.sdk.fn.data.BeamFnDataSizeBasedBufferingOutboundObserverTest | | | | - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Iterables
| | Uses | True |
checkArgument(sources.get(i).getOutputVariables().contains(Iterables.get(expectedInputs,i)),STR0); | checkArgument(sources.get(i).getOutputVariables().contains(expectedInputs.get(i)),STR1); | Iterables.get(expectedInputs,i) | expectedInputs.get(i) | presto | 332d48418da295b0da4de3e34f9c164486cabb73 | com.facebook.presto.sql.planner.plan.SetOperationNode | | _1 | expectedInputs |
---|
_2 | expectedInputs |
---|
| | - com.google.common.collect.Iterables
| | Uses | True |