Index (Flink : DataStream : API 1.20.0-cp1 API)

A B C D E F G J K N O P R S T U V W
All Classes All Packages

A

apply(Collector<OUT>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.ApplyPartitionFunction: The actual method to be applied to each partition.
apply(Collector<OUT1>, Collector<OUT2>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.TwoOutputApplyPartitionFunction: The actual method to be applied to each partition.
ApplyPartitionFunction<OUT> - Interface in org.apache.flink.datastream.api.function: A function to be applied to all partitions .
applyToAllPartitions(ApplyPartitionFunction<OUT>) - Method in interface org.apache.flink.datastream.api.context.NonPartitionedContext: Apply a function to all partitions.
applyToAllPartitions(TwoOutputApplyPartitionFunction<OUT1, OUT2>) - Method in interface org.apache.flink.datastream.api.context.TwoOutputNonPartitionedContext: Apply a function to all partitions.

B

BATCH - org.apache.flink.datastream.api.context.JobInfo.ExecutionMode
broadcast() - Method in interface org.apache.flink.datastream.api.stream.GlobalStream: Transform this stream to a new BroadcastStream.
broadcast() - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Transform this stream to a new BroadcastStream.
broadcast() - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream: Transform this stream to a new BroadcastStream.
BroadcastStream<T> - Interface in org.apache.flink.datastream.api.stream: This interface represents a stream that each parallel task processes the same data.

C

close() - Method in interface org.apache.flink.datastream.api.function.ProcessFunction: Tear-down method for the user code.
collect(OUT) - Method in interface org.apache.flink.datastream.api.common.Collector: Collect record to output stream.
collectAndOverwriteTimestamp(OUT, long) - Method in interface org.apache.flink.datastream.api.common.Collector: Overwrite the timestamp of this record and collect it to output stream.
Collector<OUT> - Interface in org.apache.flink.datastream.api.common: This class take response for collecting data to output stream.
connectAndProcess(BroadcastStream<T_OTHER>, TwoInputBroadcastStreamProcessFunction<T, T_OTHER, OUT>) - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Apply a two input operation to this and other BroadcastStream.
connectAndProcess(BroadcastStream<T_OTHER>, TwoInputBroadcastStreamProcessFunction<T, T_OTHER, OUT>) - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream: Apply a two input operation to this and other BroadcastStream.
connectAndProcess(BroadcastStream<T_OTHER>, TwoInputBroadcastStreamProcessFunction<T, T_OTHER, OUT>, KeySelector<OUT, K>) - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Apply a two input operation to this and other BroadcastStream.
connectAndProcess(GlobalStream<T_OTHER>, TwoInputNonBroadcastStreamProcessFunction<T, T_OTHER, OUT>) - Method in interface org.apache.flink.datastream.api.stream.GlobalStream: Apply a two input operation to this and other GlobalStream.
connectAndProcess(KeyedPartitionStream<K, T_OTHER>, TwoInputBroadcastStreamProcessFunction<T_OTHER, T, OUT>) - Method in interface org.apache.flink.datastream.api.stream.BroadcastStream: Apply a two input operation to this and other KeyedPartitionStream.
connectAndProcess(KeyedPartitionStream<K, T_OTHER>, TwoInputBroadcastStreamProcessFunction<T_OTHER, T, OUT>, KeySelector<OUT, K>) - Method in interface org.apache.flink.datastream.api.stream.BroadcastStream: Apply a two input operation to this and other KeyedPartitionStream.
connectAndProcess(KeyedPartitionStream<K, T_OTHER>, TwoInputNonBroadcastStreamProcessFunction<T, T_OTHER, OUT>) - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Apply a two input operation to this and other KeyedPartitionStream.
connectAndProcess(KeyedPartitionStream<K, T_OTHER>, TwoInputNonBroadcastStreamProcessFunction<T, T_OTHER, OUT>, KeySelector<OUT, K>) - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Apply a two input operation to this and other KeyedPartitionStream.The two keyed streams must have the same partitions, otherwise it makes no sense to connect them.
connectAndProcess(NonKeyedPartitionStream<T_OTHER>, TwoInputBroadcastStreamProcessFunction<T_OTHER, T, OUT>) - Method in interface org.apache.flink.datastream.api.stream.BroadcastStream: Apply a two input operation to this and other NonKeyedPartitionStream.
connectAndProcess(NonKeyedPartitionStream<T_OTHER>, TwoInputNonBroadcastStreamProcessFunction<T, T_OTHER, OUT>) - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream: Apply to a two input operation on this and other NonKeyedPartitionStream.
currentTime() - Method in interface org.apache.flink.datastream.api.context.ProcessingTimeManager: Get the current processing time.

D

DataStream - Interface in org.apache.flink.datastream.api.stream: This is the topmost base interface of all streams of DataStream V2 API.
deleteTimer(long) - Method in interface org.apache.flink.datastream.api.context.ProcessingTimeManager: Deletes the processing-time timer with the given trigger timestamp.

E

endBroadcastInput(NonPartitionedContext<OUT>) - Method in interface org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction: This is a life-cycle method indicates that this function will no longer receive any data from the broadcast input.
endFirstInput(NonPartitionedContext<OUT>) - Method in interface org.apache.flink.datastream.api.function.TwoInputNonBroadcastStreamProcessFunction: This is a life-cycle method indicates that this function will no longer receive any data from the first input.
endInput(NonPartitionedContext<OUT>) - Method in interface org.apache.flink.datastream.api.function.OneInputStreamProcessFunction: This is a life-cycle method indicates that this function will no longer receive any data from the input.
endInput(TwoOutputNonPartitionedContext<OUT1, OUT2>) - Method in interface org.apache.flink.datastream.api.function.TwoOutputStreamProcessFunction: This is a life-cycle method indicates that this function will no longer receive any input data.
endNonBroadcastInput(NonPartitionedContext<OUT>) - Method in interface org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction: This is a life-cycle method indicates that this function will no longer receive any data from the non-broadcast input.
endSecondInput(NonPartitionedContext<OUT>) - Method in interface org.apache.flink.datastream.api.function.TwoInputNonBroadcastStreamProcessFunction: This is a life-cycle method indicates that this function will no longer receive any data from the second input.
execute(String) - Method in interface org.apache.flink.datastream.api.ExecutionEnvironment: Execute and submit the job attached to this environment.
ExecutionEnvironment - Interface in org.apache.flink.datastream.api: This is the context in which a program is executed.

F

fromSource(Source<OUT>, String) - Method in interface org.apache.flink.datastream.api.ExecutionEnvironment

G

getCurrentKey() - Method in interface org.apache.flink.datastream.api.context.StateManager: Get the key of current record.
getExecutionMode() - Method in interface org.apache.flink.datastream.api.context.JobInfo: Get the JobInfo.ExecutionMode of current job.
getExecutionMode() - Method in interface org.apache.flink.datastream.api.ExecutionEnvironment: Get the execution mode of this environment.
getFirst() - Method in interface org.apache.flink.datastream.api.stream.GlobalStream.TwoGlobalStreams: Get the first stream.
getFirst() - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream.TwoKeyedPartitionStreams: Get the first stream.
getFirst() - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream.TwoNonKeyedPartitionStreams: Get the first stream.
getInstance() - Static method in interface org.apache.flink.datastream.api.ExecutionEnvironment: Get the execution environment instance.
getJobInfo() - Method in interface org.apache.flink.datastream.api.context.RuntimeContext: Get the JobInfo of this process function.
getJobName() - Method in interface org.apache.flink.datastream.api.context.JobInfo: Get the name of current job.
getMaxParallelism() - Method in interface org.apache.flink.datastream.api.context.TaskInfo: Get the max parallelism of current task.
getMetricGroup() - Method in interface org.apache.flink.datastream.api.context.RuntimeContext: Get the metric group of this process function.
getParallelism() - Method in interface org.apache.flink.datastream.api.context.TaskInfo: Get the parallelism of current task.
getProcessingTimeManager() - Method in interface org.apache.flink.datastream.api.context.PartitionedContext: Get the ProcessingTimeManager of this process function.
getSecond() - Method in interface org.apache.flink.datastream.api.stream.GlobalStream.TwoGlobalStreams: Get the second stream.
getSecond() - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream.TwoKeyedPartitionStreams: Get the second stream.
getSecond() - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream.TwoNonKeyedPartitionStreams: Get the second stream.
getState(AggregatingStateDeclaration<IN, ACC, OUT>) - Method in interface org.apache.flink.datastream.api.context.StateManager: Get the specific aggregating state.
getState(BroadcastStateDeclaration<K, V>) - Method in interface org.apache.flink.datastream.api.context.StateManager: Get the specific broadcast state.
getState(ListStateDeclaration<T>) - Method in interface org.apache.flink.datastream.api.context.StateManager: Get the specific list state.
getState(MapStateDeclaration<K, V>) - Method in interface org.apache.flink.datastream.api.context.StateManager: Get the specific map state.
getState(ReducingStateDeclaration<T>) - Method in interface org.apache.flink.datastream.api.context.StateManager: Get the specific reducing state.
getState(ValueStateDeclaration<T>) - Method in interface org.apache.flink.datastream.api.context.StateManager: Get the specific value state.
getStateManager() - Method in interface org.apache.flink.datastream.api.context.PartitionedContext: Get the StateManager of this process function.
getTaskInfo() - Method in interface org.apache.flink.datastream.api.context.RuntimeContext: Get the TaskInfo of this process function.
getTaskName() - Method in interface org.apache.flink.datastream.api.context.TaskInfo: Get the name of current task.
global() - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Coalesce this stream to a GlobalStream.
global() - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream: Coalesce this stream to a GlobalStream.
GlobalStream<T> - Interface in org.apache.flink.datastream.api.stream: This interface represents a stream that force single parallelism.
GlobalStream.ProcessConfigurableAndGlobalStream<T> - Interface in org.apache.flink.datastream.api.stream: This interface represents a configurable GlobalStream.
GlobalStream.TwoGlobalStreams<T1,T2> - Interface in org.apache.flink.datastream.api.stream: This class represents a combination of two GlobalStream.

J

JobInfo - Interface in org.apache.flink.datastream.api.context: JobInfo contains all the meta information of the job.
JobInfo.ExecutionMode - Enum in org.apache.flink.datastream.api.context: Execution mode of this current job.

K

keyBy(KeySelector<T, K>) - Method in interface org.apache.flink.datastream.api.stream.GlobalStream: Transform this stream to a KeyedPartitionStream.
keyBy(KeySelector<T, K>) - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream: Transform this stream to a KeyedPartitionStream.
keyBy(KeySelector<T, NEW_KEY>) - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Transform this stream to a new KeyedPartitionStream.
KeyedPartitionStream<K,T> - Interface in org.apache.flink.datastream.api.stream: This interface represents a kind of partitioned data stream.
KeyedPartitionStream.ProcessConfigurableAndKeyedPartitionStream<K,T> - Interface in org.apache.flink.datastream.api.stream: This interface represents a configurable KeyedPartitionStream.
KeyedPartitionStream.TwoKeyedPartitionStreams<K,T1,T2> - Interface in org.apache.flink.datastream.api.stream: This class represents a combination of two KeyedPartitionStream.

N

NonKeyedPartitionStream<T> - Interface in org.apache.flink.datastream.api.stream: This interface represents a kind of partitioned data stream.
NonKeyedPartitionStream.ProcessConfigurableAndNonKeyedPartitionStream<T> - Interface in org.apache.flink.datastream.api.stream: This interface represents a configurable NonKeyedPartitionStream.
NonKeyedPartitionStream.TwoNonKeyedPartitionStreams<T1,T2> - Interface in org.apache.flink.datastream.api.stream: This interface represents a combination of two NonKeyedPartitionStream.
NonPartitionedContext<OUT> - Interface in org.apache.flink.datastream.api.context: This interface represents the context associated with all operations must be applied to all partitions.

O

OneInputStreamProcessFunction<IN,OUT> - Interface in org.apache.flink.datastream.api.function: This contains all logical related to process records from single input.
onProcessingTimer(long, Collector<OUT>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.OneInputStreamProcessFunction: Callback for processing timer.
onProcessingTimer(long, Collector<OUT>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction: Callback for processing timer.
onProcessingTimer(long, Collector<OUT>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.TwoInputNonBroadcastStreamProcessFunction: Callback for processing timer.
onProcessingTimer(long, Collector<OUT1>, Collector<OUT2>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.TwoOutputStreamProcessFunction: Callback for processing timer.
open() - Method in interface org.apache.flink.datastream.api.function.ProcessFunction: Initialization method for the function.
org.apache.flink.datastream.api - package org.apache.flink.datastream.api
org.apache.flink.datastream.api.common - package org.apache.flink.datastream.api.common
org.apache.flink.datastream.api.context - package org.apache.flink.datastream.api.context
org.apache.flink.datastream.api.function - package org.apache.flink.datastream.api.function
org.apache.flink.datastream.api.stream - package org.apache.flink.datastream.api.stream

P

PartitionedContext - Interface in org.apache.flink.datastream.api.context: On the base of RuntimeContext, PartitionedContext also contains all partition-wise execution information, such as getting state, registering timer, etc.
process(OneInputStreamProcessFunction<T, OUT>) - Method in interface org.apache.flink.datastream.api.stream.GlobalStream: Apply an operation to this GlobalStream.
process(OneInputStreamProcessFunction<T, OUT>) - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Apply an operation to this KeyedPartitionStream.
process(OneInputStreamProcessFunction<T, OUT>) - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream: Apply an operation to this NonKeyedPartitionStream.
process(OneInputStreamProcessFunction<T, OUT>, KeySelector<OUT, K>) - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Apply an operation to this KeyedPartitionStream.
process(TwoOutputStreamProcessFunction<T, OUT1, OUT2>) - Method in interface org.apache.flink.datastream.api.stream.GlobalStream: Apply a two output operation to this GlobalStream.
process(TwoOutputStreamProcessFunction<T, OUT1, OUT2>) - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Apply a two output operation to this KeyedPartitionStream.
process(TwoOutputStreamProcessFunction<T, OUT1, OUT2>) - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream: Apply a two output operation to this NonKeyedPartitionStream.
process(TwoOutputStreamProcessFunction<T, OUT1, OUT2>, KeySelector<OUT1, K>, KeySelector<OUT2, K>) - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Apply a two output operation to this KeyedPartitionStream.
ProcessConfigurable<T extends ProcessConfigurable<T>> - Interface in org.apache.flink.datastream.api.stream: This represents the configuration handle of processing.
ProcessFunction - Interface in org.apache.flink.datastream.api.function: Base class for all user defined process functions.
ProcessingTimeManager - Interface in org.apache.flink.datastream.api.context: This is responsibility for managing runtime information related to processing time of process function.
processRecord(IN, Collector<OUT>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.OneInputStreamProcessFunction: Process record and emit data through Collector.
processRecord(IN, Collector<OUT1>, Collector<OUT2>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.TwoOutputStreamProcessFunction: Process and emit record to the first/second output through Collectors.
processRecordFromBroadcastInput(IN2, NonPartitionedContext<OUT>) - Method in interface org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction: Process record from broadcast input.
processRecordFromFirstInput(IN1, Collector<OUT>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.TwoInputNonBroadcastStreamProcessFunction: Process record from the first input and emit data through Collector.
processRecordFromNonBroadcastInput(IN1, Collector<OUT>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.TwoInputBroadcastStreamProcessFunction: Process record from non-broadcast input and emit data through Collector.
processRecordFromSecondInput(IN2, Collector<OUT>, PartitionedContext) - Method in interface org.apache.flink.datastream.api.function.TwoInputNonBroadcastStreamProcessFunction: Process record from the second input and emit data through Collector.

R

registerTimer(long) - Method in interface org.apache.flink.datastream.api.context.ProcessingTimeManager: Register a processing timer for this process function.
RuntimeContext - Interface in org.apache.flink.datastream.api.context: A RuntimeContext contains information about the context in which process functions are executed.

S

setExecutionMode(RuntimeExecutionMode) - Method in interface org.apache.flink.datastream.api.ExecutionEnvironment: Set the execution mode for this environment.
shuffle() - Method in interface org.apache.flink.datastream.api.stream.GlobalStream: Transform this stream to a new NonKeyedPartitionStream, data will be shuffled between these two streams.
shuffle() - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream: Transform this stream to a new NonKeyedPartitionStream, data will be shuffled between these two streams.
shuffle() - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream: Transform this stream to a new NonKeyedPartitionStream, data will be shuffled between these two streams.
StateManager - Interface in org.apache.flink.datastream.api.context: This is responsibility for managing runtime information related to state of process function.
STREAMING - org.apache.flink.datastream.api.context.JobInfo.ExecutionMode

T

TaskInfo - Interface in org.apache.flink.datastream.api.context: TaskInfo contains all the meta information of the task.
toSink(Sink<T>) - Method in interface org.apache.flink.datastream.api.stream.GlobalStream
toSink(Sink<T>) - Method in interface org.apache.flink.datastream.api.stream.KeyedPartitionStream
toSink(Sink<T>) - Method in interface org.apache.flink.datastream.api.stream.NonKeyedPartitionStream
TwoInputBroadcastStreamProcessFunction<IN1,IN2,OUT> - Interface in org.apache.flink.datastream.api.function: This contains all logical related to process records from a broadcast stream and a non-broadcast stream.
TwoInputNonBroadcastStreamProcessFunction<IN1,IN2,OUT> - Interface in org.apache.flink.datastream.api.function: This contains all logical related to process records from two non-broadcast input.
TwoOutputApplyPartitionFunction<OUT1,OUT2> - Interface in org.apache.flink.datastream.api.function: A function to be applied to all partitions with two outputs.
TwoOutputNonPartitionedContext<OUT1,OUT2> - Interface in org.apache.flink.datastream.api.context: This interface represents the context associated with all operations must be applied to all partitions with two outputs.
TwoOutputStreamProcessFunction<IN,OUT1,OUT2> - Interface in org.apache.flink.datastream.api.function: This contains all logical related to process and emit records to two output streams.

U

usesStates() - Method in interface org.apache.flink.datastream.api.function.ProcessFunction: Explicitly declares states upfront.

V

valueOf(String) - Static method in enum org.apache.flink.datastream.api.context.JobInfo.ExecutionMode: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.flink.datastream.api.context.JobInfo.ExecutionMode: Returns an array containing the constants of this enum type, in the order they are declared.

W

withMaxParallelism(int) - Method in interface org.apache.flink.datastream.api.stream.ProcessConfigurable: Sets the maximum parallelism of this operator.
withName(String) - Method in interface org.apache.flink.datastream.api.stream.ProcessConfigurable: Sets the name of the current data stream.
withParallelism(int) - Method in interface org.apache.flink.datastream.api.stream.ProcessConfigurable: Sets the parallelism for this process operator.
withSlotSharingGroup(SlotSharingGroup) - Method in interface org.apache.flink.datastream.api.stream.ProcessConfigurable: Sets the slot sharing group of this operation.
withUid(String) - Method in interface org.apache.flink.datastream.api.stream.ProcessConfigurable: Sets an ID for this operator.

A B C D E F G J K N O P R S T U V W
All Classes All Packages