Uses of Class
org.apache.nemo.compiler.frontend.beam.SideInputElement
-
Packages that use SideInputElement Package Description org.apache.nemo.compiler.frontend.beam org.apache.nemo.compiler.frontend.beam.coder org.apache.nemo.compiler.frontend.beam.transform -
-
Uses of SideInputElement in org.apache.nemo.compiler.frontend.beam
Method parameters in org.apache.nemo.compiler.frontend.beam with type arguments of type SideInputElement Modifier and Type Method Description voidInMemorySideInputReader. addSideInputElement(org.apache.beam.sdk.values.PCollectionView<?> view, org.apache.beam.sdk.util.WindowedValue<SideInputElement<?>> sideInputElement)Stores the side input in memory to be used with main inputs. -
Uses of SideInputElement in org.apache.nemo.compiler.frontend.beam.coder
Methods in org.apache.nemo.compiler.frontend.beam.coder that return SideInputElement Modifier and Type Method Description SideInputElement<T>SideInputCoder. decode(InputStream inStream)Methods in org.apache.nemo.compiler.frontend.beam.coder with parameters of type SideInputElement Modifier and Type Method Description voidSideInputCoder. encode(SideInputElement<T> sideInputElement, OutputStream outStream) -
Uses of SideInputElement in org.apache.nemo.compiler.frontend.beam.transform
Method parameters in org.apache.nemo.compiler.frontend.beam.transform with type arguments of type SideInputElement Modifier and Type Method Description voidSideInputTransform. prepare(Transform.Context context, OutputCollector<org.apache.beam.sdk.util.WindowedValue<SideInputElement<T>>> oc)
-