Package | Description |
---|---|
org.apache.flink.state.api | |
org.apache.flink.state.api.output |
Modifier and Type | Method and Description |
---|---|
OneInputOperatorTransformation<T> |
OneInputOperatorTransformation.assignTimestamps(Timestamper<T> timestamper)
Deprecated.
Assigns an event time timestamp to each record.
|
Modifier and Type | Class and Description |
---|---|
class |
TimestampAssignerWrapper<T>
Deprecated.
|
Constructor and Description |
---|
BoundedOneInputStreamTaskRunner(StreamConfig streamConfig,
int maxParallelism,
Timestamper<IN> timestamper)
Deprecated.
Create a new
BoundedOneInputStreamTaskRunner . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.