org.apache.flink.api.scala.extensions.impl.acceptPartialFunctions

Classes

• OnCoGroupDataSet
• OnCrossDataSet
• OnDataSet
• OnGroupedDataSet
• OnHalfUnfinishedKeyPairOperation
• OnJoinFunctionAssigner
• OnUnfinishedKeyPairOperation