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 -
-
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(java.io.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, java.io.OutputStream outStream)
-