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, ListCheckpointed<Integer>

Enclosing class:

StreamSQLTestProgram

public static class StreamSQLTestProgram.KillMapper
extends Object
implements MapFunction<Row,Row>, ListCheckpointed<Integer>, 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.
Row	map(Row value) The mapping method.
void	restoreState(List<Integer> state) Restores the state of the function or operator to that of a previous checkpoint.
List<Integer>	snapshotState(long checkpointId, long timestamp) Gets the current state of the function.

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.

snapshotState

public List<Integer> snapshotState(long checkpointId,
                                   long timestamp)

Description copied from interface: ListCheckpointed

Gets the current state of the function. The state must reflect the result of all prior invocations to this function.

The returned list should contain one entry for redistributable unit of state. See the class docs for an illustration how list-style state redistribution works.

As special case, the returned list may be null or empty (if the operator has no state) or it may contain a single element (if the operator state is indivisible).

Specified by:

snapshotState in interface ListCheckpointed<Integer>

Parameters:

checkpointId - The ID of the checkpoint - a unique and monotonously increasing value.

timestamp - The wall clock timestamp when the checkpoint was triggered by the master.

Returns:

The operator state in a list of redistributable, atomic sub-states. Should not return null, but empty list instead.

restoreState

public void restoreState(List<Integer> state)

Description copied from interface: ListCheckpointed

Restores the state of the function or operator to that of a previous checkpoint. This method is invoked when the function is executed after a failure recovery. The state list may be empty if no state is to be recovered by the particular parallel instance of the function.

The given state list will contain all the sub states that this parallel instance of the function needs to handle. Refer to the class docs for an illustration how list-style state redistribution works.

Important: When implementing this interface together with RichFunction, then the restoreState() method is called before RichFunction.open(Configuration).

Specified by:

restoreState in interface ListCheckpointed<Integer>

Parameters:

state - The state to be restored as a list of atomic sub-states.