Toggle navigation
Home
org.apache.flink.cep.StreamEvent to org.apache.flink.streaming.runtime.streamrecord.StreamRecord
No. of Instances - 12
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Similar)
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
StreamEvent<Event>
to
StreamRecord<Event>
Add or Remove Method invocation
nfa.process(streamEvent.getEvent(),streamEvent.getTimestamp())
to
nfa.process(streamEvent.getValue(),streamEvent.getTimestamp())
nfa.process(inputEvent.getEvent(),inputEvent.getTimestamp())
to
nfa.process(inputEvent.getValue(),inputEvent.getTimestamp())
event.getEvent()
to
event.getValue()
nfa.process(event.getEvent(),event.getTimestamp())
to
nfa.process(event.getValue(),event.getTimestamp())