org.apache.beam.runners.twister2.translators.functions

Classes

• AssignWindowsFunction
• ByteToWindowFunction
• DoFnFunction
• GroupByWindowFunction
• MapToTupleFunction
• OutputTagFilter
• SideInputSinkFunction
• Twister2SinkFunction