return Optional.of(Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length()))); | return Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length())); | Optional.of(Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length()))) | Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length())) | beam | 4c18cb4ada2650552a0006dfffd68d0775dd76c6 | org.apache.beam.runners.dataflow.worker.fn.data.BeamFnDataGrpcService | | _1 | getOutboundBufferLimit |
---|
_2 | getSizeLimit |
---|
| v0 | Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length())) |
---|
| - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.base.Optional
| v0 | Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length())) |
---|
| Returns | True |
return Optional.of(Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length()))); | return Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length())); | Optional.of(Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length()))) | Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length())) | beam | 4c18cb4ada2650552a0006dfffd68d0775dd76c6 | org.apache.beam.fn.harness.data.BeamFnDataGrpcClient | | _1 | getBufferLimit |
---|
_2 | getSizeLimit |
---|
| v0 | Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length())) |
---|
| | v0 | Integer.parseInt(experiment.substring(BEAM_FN_API_DATA_BUFFER_LIMIT.length())) |
---|
| Returns | True |