适用于所有输入

我FlinkKafkaConsumer011订阅了一个主题。我希望apply在每个kafka consumer消息上进行process（），因此custom FooTrigger会返回TriggerResult.FIRE每个元素。

下面的代码工作，我只是感到困惑timeWindowAll(Time.minutes(1))。看起来我做错了什么。

// set up streaming execution environment
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime);

// create a Kafka consumer
FlinkKafkaConsumer011 consumer = new FlinkKafkaConsumer011<>(

"topic",
new Foo.FooSchema(),
props);   // Properties object

// create Kafka consumer data source
DataStream trades = env.addSource(consumer)

.timeWindowAll(Time.minutes(1))
.trigger(new FooTrigger())
.evictor(new FooEvictor())
.apply(new CreateFoos());