flink-statefulfun-0.4.0.0: Flink stateful functions SDK

Index

Address 
1 (Type/Class)Proto.RequestReply
2 (Type/Class)Network.Flink.Internal.Stateful, Network.Flink.Stateful
3 (Data Constructor)Network.Flink.Internal.Stateful, Network.Flink.Stateful
Address'Network.Flink.Internal.Stateful, Network.Flink.Stateful
AFTER_CALLNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
AFTER_WRITENetwork.Flink.Internal.Stateful, Network.Flink.Stateful
argumentProto.RequestReply_Fields
callerProto.RequestReply_Fields
createAppNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
delayedInvocationsProto.RequestReply_Fields
delayInMsProto.RequestReply_Fields
deserializeBytesNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
egressNamespaceProto.RequestReply_Fields
egressTypeProto.RequestReply_Fields
emodeNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
EmptyArgumentPassedNetwork.Flink.Internal.Stateful
Env 
1 (Type/Class)Network.Flink.Internal.Stateful
2 (Data Constructor)Network.Flink.Internal.Stateful
envFunctionIdNetwork.Flink.Internal.Stateful
envFunctionNamespaceNetwork.Flink.Internal.Stateful
envFunctionTypeNetwork.Flink.Internal.Stateful
Expiration 
1 (Type/Class)Network.Flink.Internal.Stateful, Network.Flink.Stateful
2 (Data Constructor)Network.Flink.Internal.Stateful, Network.Flink.Stateful
ExpirationModeNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
expirationSpecProto.RequestReply_Fields
expireAfterMillis 
1 (Function)Proto.RequestReply_Fields
2 (Function)Network.Flink.Internal.Stateful, Network.Flink.Stateful
flinkApiNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
FlinkErrorNetwork.Flink.Internal.Stateful
flinkServerNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
flinkWrapperNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
FromFunctionProto.RequestReply
FromFunction'DelayedInvocationProto.RequestReply
FromFunction'EgressMessageProto.RequestReply
FromFunction'ExpirationSpecProto.RequestReply
FromFunction'ExpirationSpec'AFTER_INVOKEProto.RequestReply
FromFunction'ExpirationSpec'AFTER_WRITEProto.RequestReply
FromFunction'ExpirationSpec'ExpireModeProto.RequestReply
FromFunction'ExpirationSpec'ExpireMode'UnrecognizedProto.RequestReply
FromFunction'ExpirationSpec'ExpireMode'UnrecognizedValueProto.RequestReply
FromFunction'ExpirationSpec'NONEProto.RequestReply
FromFunction'IncompleteInvocationContextProto.RequestReply
FromFunction'IncompleteInvocationContext'Proto.RequestReply
FromFunction'InvocationProto.RequestReply
FromFunction'InvocationResponseProto.RequestReply
FromFunction'InvocationResultProto.RequestReply
FromFunction'PersistedValueMutationProto.RequestReply
FromFunction'PersistedValueMutation'DELETEProto.RequestReply
FromFunction'PersistedValueMutation'MODIFYProto.RequestReply
FromFunction'PersistedValueMutation'MutationTypeProto.RequestReply
FromFunction'PersistedValueMutation'MutationType'UnrecognizedProto.RequestReply
FromFunction'PersistedValueMutation'MutationType'UnrecognizedValueProto.RequestReply
FromFunction'PersistedValueSpecProto.RequestReply
FromFunction'ResponseProto.RequestReply
Function 
1 (Type/Class)Network.Flink.Internal.Stateful
2 (Data Constructor)Network.Flink.Internal.Stateful
FunctionState 
1 (Type/Class)Network.Flink.Internal.Stateful
2 (Data Constructor)Network.Flink.Internal.Stateful
functionStateCtxNetwork.Flink.Internal.Stateful
functionStateDelayedInvocationsNetwork.Flink.Internal.Stateful
functionStateEgressMessagesNetwork.Flink.Internal.Stateful
functionStateInvocationsNetwork.Flink.Internal.Stateful
functionStateMutatedNetwork.Flink.Internal.Stateful
FunctionTableNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
FuncType 
1 (Type/Class)Network.Flink.Internal.Stateful, Network.Flink.Stateful
2 (Data Constructor)Network.Flink.Internal.Stateful, Network.Flink.Stateful
getCtxNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
getJsonNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
getProtoNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
hasValueProto.RequestReply_Fields
idProto.RequestReply_Fields
incompleteInvocationContextProto.RequestReply_Fields
insideCtxNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
InvalidTypePassedErrorNetwork.Flink.Internal.Stateful
invocationProto.RequestReply_Fields
invocationResultProto.RequestReply_Fields
invocationsProto.RequestReply_Fields
JsonSerde 
1 (Type/Class)Network.Flink.Internal.Stateful, Network.Flink.Stateful
2 (Data Constructor)Network.Flink.Internal.Stateful, Network.Flink.Stateful
jsonStateNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
KafkaProducerRecordProto.Kafka
kafkaRecordNetwork.Flink.Kafka
keyProto.Kafka_Fields
maybe'argumentProto.RequestReply_Fields
maybe'callerProto.RequestReply_Fields
maybe'expirationSpecProto.RequestReply_Fields
maybe'incompleteInvocationContextProto.RequestReply_Fields
maybe'invocationProto.RequestReply_Fields
maybe'invocationResultProto.RequestReply_Fields
maybe'requestProto.RequestReply_Fields
maybe'responseProto.RequestReply_Fields
maybe'stateValueProto.RequestReply_Fields
maybe'targetProto.RequestReply_Fields
MessageDecodeErrorNetwork.Flink.Internal.Stateful
MissingInvocationBatchNetwork.Flink.Internal.Stateful
missingValuesProto.RequestReply_Fields
modeProto.RequestReply_Fields
modifyCtxNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
mutationTypeProto.RequestReply_Fields
namespaceProto.RequestReply_Fields
newStateNetwork.Flink.Internal.Stateful
NONENetwork.Flink.Internal.Stateful, Network.Flink.Stateful
NoSuchFunctionNetwork.Flink.Internal.Stateful
outgoingEgressesProto.RequestReply_Fields
outgoingMessagesProto.RequestReply_Fields
ProtodeserializeBytesErrorNetwork.Flink.Internal.Stateful
ProtoMessageDecodeErrorNetwork.Flink.Internal.Stateful
ProtoSerde 
1 (Type/Class)Network.Flink.Internal.Stateful, Network.Flink.Stateful
2 (Data Constructor)Network.Flink.Internal.Stateful, Network.Flink.Stateful
protoStateNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
runFunctionNetwork.Flink.Internal.Stateful
sendEgressMsgNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
sendMsgNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
sendMsgDelayNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
sendProtoMsgNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
sendProtoMsgDelayNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
SerdeNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
serializeBytesNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
setCtxNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
stateProto.RequestReply_Fields
StateDecodeErrorNetwork.Flink.Internal.Stateful
StatefulFuncNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
stateMutationsProto.RequestReply_Fields
stateNameProto.RequestReply_Fields
stateValueProto.RequestReply_Fields
targetProto.RequestReply_Fields
testStatefulFuncNetwork.Flink.Test
ToFunctionProto.RequestReply
ToFunction'InvocationProto.RequestReply
ToFunction'Invocation'Proto.RequestReply
ToFunction'InvocationBatchRequestProto.RequestReply
ToFunction'PersistedValueProto.RequestReply
ToFunction'RequestProto.RequestReply
topicProto.Kafka_Fields
tpNameNetwork.Flink.Internal.Stateful, Network.Flink.Stateful
type'Proto.RequestReply_Fields
TypedValueProto.RequestReply
typenameProto.RequestReply_Fields
typeTypenameProto.RequestReply_Fields
valueProto.RequestReply_Fields
valueBytesProto.Kafka_Fields
vec'delayedInvocationsProto.RequestReply_Fields
vec'invocationsProto.RequestReply_Fields
vec'missingValuesProto.RequestReply_Fields
vec'outgoingEgressesProto.RequestReply_Fields
vec'outgoingMessagesProto.RequestReply_Fields
vec'stateProto.RequestReply_Fields
vec'stateMutationsProto.RequestReply_Fields
_FromFunction'IncompleteInvocationContext'Proto.RequestReply
_FromFunction'InvocationResultProto.RequestReply
_ToFunction'Invocation'Proto.RequestReply