Package | Description |
---|---|
org.apache.flink.streaming.api | |
org.apache.flink.streaming.api.environment | |
org.apache.flink.streaming.api.graph | |
org.apache.flink.streaming.api.scala |
Modifier and Type | Method and Description |
---|---|
static TimeCharacteristic |
TimeCharacteristic.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static TimeCharacteristic[] |
TimeCharacteristic.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
TimeCharacteristic |
StreamExecutionEnvironment.getStreamTimeCharacteristic()
Gets the time characteristic.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic characteristic)
Sets the time characteristic for all streams create from this environment, e.g., processing
time, event time, or ingestion time.
|
Modifier and Type | Method and Description |
---|---|
TimeCharacteristic |
StreamConfig.getTimeCharacteristic() |
Modifier and Type | Method and Description |
---|---|
void |
StreamConfig.setTimeCharacteristic(TimeCharacteristic characteristic) |
Modifier and Type | Method and Description |
---|---|
TimeCharacteristic |
StreamExecutionEnvironment.getStreamTimeCharacteristic()
Gets the time characteristic/
|
Modifier and Type | Method and Description |
---|---|
void |
StreamExecutionEnvironment.setStreamTimeCharacteristic(TimeCharacteristic characteristic)
Sets the time characteristic for all streams create from this environment, e.g., processing
time, event time, or ingestion time.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.