Packages

package source

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

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" ) @nowarn( "cat=deprecation" )
  2. case class CollectionSource[T](config: ExecutionConfig, list: List[T], timestampAssigner: Option[TimestampWatermarkHandler[T]], returnType: TypingResult)(implicit evidence$1: TypeInformation[T]) extends BasicFlinkSource[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" ) @nowarn( "cat=deprecation" )
  4. case class EmptySource[T](returnType: TypingResult)(implicit evidence$1: TypeInformation[T]) extends BasicFlinkSource[T] with ReturningType with Product with Serializable
  5. class EmptySourceFunction[T] extends SourceFunction[T]
  6. class EspDeserializationSchema[T] extends AbstractDeserializationSchema[T]
  7. class ReturningClassInstanceSource extends SourceFactory
  8. case class ReturningTestCaseClass(someMethod: String) extends Product with Serializable

Value Members

  1. object BlockingQueueSource extends Serializable
  2. object EmitWatermarkAfterEachElementCollectionSource
  3. object StaticSource extends SourceFunction[String]

Ungrouped