org.apache.flink.sql.tests

Class StreamSQLTestProgram.KillMapper

java.lang.Object

org.apache.flink.sql.tests.StreamSQLTestProgram.KillMapper

All Implemented Interfaces:

Serializable, Function, MapFunction<Row,Row>, ResultTypeQueryable, CheckpointedFunction

Enclosing class:

StreamSQLTestProgram

public static class StreamSQLTestProgram.KillMapper
extends Object
implements MapFunction<Row,Row>, CheckpointedFunction, ResultTypeQueryable

Kills the first execution attempt of an application when it receives the second record.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
KillMapper()

Method Summary

Modifier and Type	Method and Description
TypeInformation	getProducedType() Gets the data type (as a TypeInformation) produced by this function or input format.
void	initializeState(FunctionInitializationContext context) This method is called when the parallel function instance is created during distributed execution.
Row	map(Row value) The mapping method.
void	snapshotState(FunctionSnapshotContext context) This method is called when a snapshot for a checkpoint is requested.

Methods inherited from class java.lang.Object

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

Constructor Detail

KillMapper

public KillMapper()

Method Detail

map

public Row map(Row value)

Description copied from interface: MapFunction

The mapping method. Takes an element from the input data set and transforms it into exactly one element.

Specified by:

map in interface MapFunction<Row,Row>

Parameters:

value - The input value.

Returns:

The transformed value

getProducedType

public TypeInformation getProducedType()

Description copied from interface: ResultTypeQueryable

Gets the data type (as a TypeInformation) produced by this function or input format.

Specified by:

getProducedType in interface ResultTypeQueryable

Returns:

The data type produced by this function or input format.

initializeState

public void initializeState(FunctionInitializationContext context)
                     throws Exception

Description copied from interface: CheckpointedFunction

This method is called when the parallel function instance is created during distributed execution. Functions typically set up their state storing data structures in this method.

Specified by:

initializeState in interface CheckpointedFunction

Parameters:

context - the context for initializing the operator

Throws:

Exception - Thrown, if state could not be created ot restored.

snapshotState

public void snapshotState(FunctionSnapshotContext context)
                   throws Exception

Description copied from interface: CheckpointedFunction

This method is called when a snapshot for a checkpoint is requested. This acts as a hook to the function to ensure that all state is exposed by means previously offered through FunctionInitializationContext when the Function was initialized, or offered now by FunctionSnapshotContext itself.

Specified by:

snapshotState in interface CheckpointedFunction

Parameters:

context - the context for drawing a snapshot of the operator

Throws:

Exception - Thrown, if state could not be created ot restored.