Package org.apache.flink.walkthrough.common.source

Class TransactionSource

java.lang.Object

org.apache.flink.streaming.api.functions.source.legacy.FromIteratorFunction<Transaction>

org.apache.flink.walkthrough.common.source.TransactionSource

All Implemented Interfaces:

Serializable, Function, SourceFunction<Transaction>

@Deprecated
public class TransactionSource
extends FromIteratorFunction<Transaction>

Deprecated.

This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.

A stream of transactions.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.source.legacy.SourceFunction

SourceFunction.SourceContext<T>

Constructor Summary

Constructors

Constructor	Description
TransactionSource()	Deprecated.

Method Summary

Methods inherited from class org.apache.flink.streaming.api.functions.source.legacy.FromIteratorFunction

cancel, run

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransactionSource

public TransactionSource()

Deprecated.