Package cz.o2.proxima.flink.core

Class CommitLogSourceFunction<OutputT>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction<OutputT>

cz.o2.proxima.flink.core.CommitLogSourceFunction<OutputT>

All Implemented Interfaces:

java.io.Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, org.apache.flink.api.common.state.CheckpointListener, org.apache.flink.streaming.api.checkpoint.CheckpointedFunction, org.apache.flink.streaming.api.functions.source.ParallelSourceFunction<OutputT>, org.apache.flink.streaming.api.functions.source.SourceFunction<OutputT>

@Experimental("API can be changed.")
public class CommitLogSourceFunction<OutputT>
extends org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction<OutputT>

See Also:

Serialized Form

Nested Class Summary

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

org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<T extends java.lang.Object>

Constructor Summary

Constructors

Constructor	Description
CommitLogSourceFunction(RepositoryFactory repositoryFactory, java.util.List<AttributeDescriptor<?>> attributeDescriptors, ResultExtractor<OutputT> resultExtractor)

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	close()
void	initializeState(org.apache.flink.runtime.state.FunctionInitializationContext context)
void	notifyCheckpointComplete(long l)
void	open(org.apache.flink.configuration.Configuration parameters)
void	run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<OutputT> sourceContext)
void	snapshotState(org.apache.flink.runtime.state.FunctionSnapshotContext functionSnapshotContext)

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.state.CheckpointListener

notifyCheckpointAborted

Constructor Detail

CommitLogSourceFunction

public CommitLogSourceFunction(RepositoryFactory repositoryFactory,
                               java.util.List<AttributeDescriptor<?>> attributeDescriptors,
                               ResultExtractor<OutputT> resultExtractor)

Method Detail

open

public void open(org.apache.flink.configuration.Configuration parameters)

Specified by:

open in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

open in class org.apache.flink.api.common.functions.AbstractRichFunction

run

public void run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<OutputT> sourceContext)
         throws java.lang.Exception

Specified by:

run in interface org.apache.flink.streaming.api.functions.source.SourceFunction<ReaderT>

Throws:

java.lang.Exception

cancel

public void cancel()

Specified by:

cancel in interface org.apache.flink.streaming.api.functions.source.SourceFunction<ReaderT>

close

public void close()

Specified by:

close in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

close in class org.apache.flink.api.common.functions.AbstractRichFunction

notifyCheckpointComplete

public void notifyCheckpointComplete(long l)

Specified by:

notifyCheckpointComplete in interface org.apache.flink.api.common.state.CheckpointListener

snapshotState

public void snapshotState(org.apache.flink.runtime.state.FunctionSnapshotContext functionSnapshotContext)
                   throws java.lang.Exception

Specified by:

snapshotState in interface org.apache.flink.streaming.api.checkpoint.CheckpointedFunction

Throws:

java.lang.Exception

initializeState

public void initializeState(org.apache.flink.runtime.state.FunctionInitializationContext context)
                     throws java.lang.Exception

Specified by:

initializeState in interface org.apache.flink.streaming.api.checkpoint.CheckpointedFunction

Throws:

java.lang.Exception