Type Members

1.  class BlockingQueueSource[T] extends FlinkSource with Serializable

   This source allow to add elements after creation or decide when input stream is finished.

   This source allow to add elements after creation or decide when input stream is finished. It also emit watermark after each added element.

   Annotations

   @silent("deprecated")

2.  case class CollectionSource[T](list: List[T], timestampAssigner: Option[TimestampWatermarkHandler[T]], returnType: TypingResult, boundedness: Boundedness = Boundedness.CONTINUOUS_UNBOUNDED) extends StandardFlinkSource[T] with ReturningType with Product with Serializable
3.  class EmitWatermarkAfterEachElementCollectionSource[T] extends FlinkSource

   This source in contrary to CollectionSource emit watermark after each element.

   This source in contrary to CollectionSource emit watermark after each element. It is important feature during tests if you want to make them deterministic.

   Annotations

   @silent("deprecated")

4.  case class EmptySource(returnType: TypingResult) extends StandardFlinkSource[Any] with ReturningType with Product with Serializable
5.  class EspDeserializationSchema[T] extends AbstractDeserializationSchema[T]
6.  class ReturningClassInstanceSource extends SourceFactory with UnboundedStreamComponent
7.  case class ReturningTestCaseClass(someMethod: String) extends Product with Serializable