trait FlinkIntermediateRawSource[Raw] extends ExplicitUidInOperatorsSupport
Source with typical source stream trasformations:
- adds source using provided SourceFunction (here raw source produces raw data) 2. sets UID 3. assigns timestamp and watermarks 4. initializes Context that is streamed within output DataStream (here raw data are mapped to Context) It separates raw event data produced by SourceFunction and data released to the stream as Context variables. By default it uses basic "single input value" implementation of initializer, see BasicContextInitializer.
- Raw
- type of raw event that is generated by flink source function.
- Self Type
- FlinkIntermediateRawSource[Raw] with Source
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- FlinkIntermediateRawSource
- ExplicitUidInOperatorsSupport
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Abstract Value Members
- abstract def timestampAssigner: Option[TimestampWatermarkHandler[Raw]]
- abstract def typeInformation: TypeInformation[Raw]
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @HotSpotIntrinsicCandidate()
- val contextInitializer: ContextInitializer[Raw]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
explicitUidInStatefulOperators(nodeCtx: FlinkCustomNodeContext): Boolean
Rewrite it if you wan to change globally configured behaviour of setting uid with local one
Rewrite it if you wan to change globally configured behaviour of setting uid with local one
- Attributes
- protected
- Definition Classes
- ExplicitUidInOperatorsSupport
- Annotations
- @Public()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def prepareSourceStream(env: StreamExecutionEnvironment, flinkNodeContext: FlinkCustomNodeContext, sourceFunction: SourceFunction[Raw]): DataStream[Context]
-
def
setUidToNodeIdIfNeed[T](nodeCtx: FlinkCustomNodeContext, stream: SingleOutputStreamOperator[T]): SingleOutputStreamOperator[T]
- Attributes
- protected
- Definition Classes
- ExplicitUidInOperatorsSupport
-
def
setUidToNodeIdIfNeed[T](nodeCtx: FlinkCustomNodeContext, stream: DataStreamSink[T]): DataStreamSink[T]
- Attributes
- protected
- Definition Classes
- ExplicitUidInOperatorsSupport
-
def
setUidToNodeIdIfNeed[T](nodeCtx: FlinkCustomNodeContext, stream: DataStream[T]): DataStream[T]
- Attributes
- protected
- Definition Classes
- ExplicitUidInOperatorsSupport
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
- Deprecated
(Since version ) see corresponding Javadoc for more information.