package operators
Type Members
-
class
ScalaAggregateOperator[IN] extends SingleInputOperator[IN, IN, ScalaAggregateOperator[IN]]
This operator represents the application of a "aggregate" operation on a data set, and the result data set produced by the function.
This operator represents the application of a "aggregate" operation on a data set, and the result data set produced by the function.
- Deprecated
All Flink Scala APIs are deprecated and will be removed in a future Flink major version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.
- See also
-
class
ScalaCsvOutputFormat[T <: Product] extends FileOutputFormat[T] with InputTypeConfigurable
This is an OutputFormat to serialize Scala Tuples to text.
This is an OutputFormat to serialize Scala Tuples to text. The output is structured by record delimiters and field delimiters as common in CSV files. Record delimiter separate records from each other ('\n' is common). Field delimiters separate fields within a record.
- Deprecated
All Flink Scala APIs are deprecated and will be removed in a future Flink major version. You can still build your application in Scala, but you should move to the Java version of either the DataStream and/or Table API.
- See also