Package | Description |
---|---|
org.apache.flink.streaming.scala.examples.join |
Modifier and Type | Method and Description |
---|---|
static DataStream<WindowJoin.Person> |
WindowJoin.joinStreams(DataStream<WindowJoin.Grade> grades,
DataStream<WindowJoin.Salary> salaries,
long windowSize) |
DataStream<WindowJoin.Person> |
WindowJoin$.joinStreams(DataStream<WindowJoin.Grade> grades,
DataStream<WindowJoin.Salary> salaries,
long windowSize) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.