c

pl.touk.nussknacker.engine.flink.test

MiniClusterExecutionEnvironment

class MiniClusterExecutionEnvironment extends StreamExecutionEnvironment with LazyLogging with Matchers

Linear Supertypes
Matchers, Explicitly, MatcherWords, ShouldVerb, Tolerance, Assertions, TripleEquals, TripleEqualsSupport, LazyLogging, StreamExecutionEnvironment, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MiniClusterExecutionEnvironment
  2. Matchers
  3. Explicitly
  4. MatcherWords
  5. ShouldVerb
  6. Tolerance
  7. Assertions
  8. TripleEquals
  9. TripleEqualsSupport
  10. LazyLogging
  11. StreamExecutionEnvironment
  12. AnyRef
  13. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MiniClusterExecutionEnvironment(flinkMiniClusterHolder: FlinkMiniClusterHolder, userFlinkClusterConfig: Configuration, envConfig: AdditionalEnvironmentConfig)

Type Members

  1. final class AWord extends AnyRef
    Definition Classes
    Matchers
  2. final class AnWord extends AnyRef
    Definition Classes
    Matchers
  3. sealed class AnyShouldWrapper[T] extends AnyRef
    Definition Classes
    Matchers
  4. class AssertionsHelper extends AnyRef
    Definition Classes
    Assertions
  5. class CheckingEqualizer[L] extends AnyRef
    Definition Classes
    TripleEqualsSupport
  6. class DecidedByEquality[A] extends Equality[A]
    Definition Classes
    Explicitly
  7. class DecidedWord extends AnyRef
    Definition Classes
    Explicitly
  8. class DeterminedByEquivalence[T] extends Equivalence[T]
    Definition Classes
    Explicitly
  9. class DeterminedWord extends AnyRef
    Definition Classes
    Explicitly
  10. class Equalizer[L] extends AnyRef
    Definition Classes
    TripleEqualsSupport
  11. final class HavePropertyMatcherGenerator extends AnyRef
    Definition Classes
    Matchers
  12. final class KeyWord extends AnyRef
    Definition Classes
    Matchers
  13. final class PlusOrMinusWrapper[T] extends AnyRef
    Definition Classes
    Tolerance
  14. final class RegexWord extends AnyRef
    Definition Classes
    Matchers
  15. final class RegexWrapper extends AnyRef
    Definition Classes
    Matchers
  16. class ResultOfBeWordForAny[T] extends AnyRef
    Definition Classes
    Matchers
  17. sealed class ResultOfBeWordForCollectedAny[T] extends AnyRef
    Definition Classes
    Matchers
  18. final class ResultOfBeWordForCollectedArray[T] extends ResultOfBeWordForCollectedAny[Array[T]]
    Definition Classes
    Matchers
  19. final class ResultOfCollectedAny[T] extends AnyRef
    Definition Classes
    Matchers
  20. final class ResultOfContainWordForCollectedAny[T] extends AnyRef
    Definition Classes
    Matchers
  21. final class ResultOfEndWithWordForCollectedString extends AnyRef
    Definition Classes
    Matchers
  22. final class ResultOfEndWithWordForString extends AnyRef
    Definition Classes
    Matchers
  23. final class ResultOfFullyMatchWordForCollectedString extends AnyRef
    Definition Classes
    Matchers
  24. final class ResultOfFullyMatchWordForString extends AnyRef
    Definition Classes
    Matchers
  25. final class ResultOfHaveWordForCollectedExtent[A] extends AnyRef
    Definition Classes
    Matchers
  26. final class ResultOfHaveWordForExtent[A] extends AnyRef
    Definition Classes
    Matchers
  27. final class ResultOfIncludeWordForCollectedString extends AnyRef
    Definition Classes
    Matchers
  28. final class ResultOfIncludeWordForString extends AnyRef
    Definition Classes
    Matchers
  29. final class ResultOfNotWordForCollectedAny[T] extends AnyRef
    Definition Classes
    Matchers
  30. final class ResultOfStartWithWordForCollectedString extends AnyRef
    Definition Classes
    Matchers
  31. final class ResultOfStartWithWordForString extends AnyRef
    Definition Classes
    Matchers
  32. final class StringShouldWrapper extends AnyShouldWrapper[String] with org.scalatest.Matchers.StringShouldWrapperForVerb
    Definition Classes
    Matchers
  33. trait StringShouldWrapperForVerb extends AnyRef
    Definition Classes
    ShouldVerb
  34. class TheAfterWord extends AnyRef
    Definition Classes
    Explicitly
  35. final class TheSameInstanceAsPhrase extends AnyRef
    Definition Classes
    Matchers
  36. final class ValueWord extends AnyRef
    Definition Classes
    Matchers

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. def !==[T](right: Spread[T]): TripleEqualsInvocationOnSpread[T]
    Definition Classes
    TripleEqualsSupport
  3. def !==(right: Null): TripleEqualsInvocation[Null]
    Definition Classes
    TripleEqualsSupport
  4. def !==[T](right: T): TripleEqualsInvocation[T]
    Definition Classes
    TripleEqualsSupport
  5. final def ##(): Int
    Definition Classes
    AnyRef → Any
  6. def <[T](right: T)(implicit arg0: Ordering[T]): ResultOfLessThanComparison[T]
    Definition Classes
    Matchers
  7. def <=[T](right: T)(implicit arg0: Ordering[T]): ResultOfLessThanOrEqualToComparison[T]
    Definition Classes
    Matchers
  8. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. def ===[T](right: Spread[T]): TripleEqualsInvocationOnSpread[T]
    Definition Classes
    TripleEqualsSupport
  10. def ===(right: Null): TripleEqualsInvocation[Null]
    Definition Classes
    TripleEqualsSupport
  11. def ===[T](right: T): TripleEqualsInvocation[T]
    Definition Classes
    TripleEqualsSupport
  12. def >[T](right: T)(implicit arg0: Ordering[T]): ResultOfGreaterThanComparison[T]
    Definition Classes
    Matchers
  13. def >=[T](right: T)(implicit arg0: Ordering[T]): ResultOfGreaterThanOrEqualToComparison[T]
    Definition Classes
    Matchers
  14. def a[T](implicit arg0: ClassTag[T]): ResultOfATypeInvocation[T]
    Definition Classes
    Matchers
  15. val a: AWord
    Definition Classes
    Matchers
  16. def addDefaultKryoSerializer(arg0: Class[_], arg1: Class[_ <: Serializer[_]]): Unit
    Definition Classes
    StreamExecutionEnvironment
  17. def addDefaultKryoSerializer[T <: Serializer[_] with Serializable](arg0: Class[_], arg1: T): Unit
    Definition Classes
    StreamExecutionEnvironment
  18. def addOperator(arg0: Transformation[_]): Unit
    Definition Classes
    StreamExecutionEnvironment
  19. def addSource[OUT](arg0: SourceFunction[OUT], arg1: String, arg2: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  20. def addSource[OUT](arg0: SourceFunction[OUT], arg1: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  21. def addSource[OUT](arg0: SourceFunction[OUT], arg1: String): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  22. def addSource[OUT](arg0: SourceFunction[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  23. val after: TheAfterWord
    Definition Classes
    Explicitly
  24. def all(xs: String)(implicit collecting: Collecting[Char, String], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Char]
    Definition Classes
    Matchers
  25. def all[K, V, JMAP[k, v] <: Map[k, v]](xs: JMAP[K, V])(implicit collecting: Collecting[Entry[K, V], JMAP[K, V]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Entry[K, V]]
    Definition Classes
    Matchers
  26. def all[K, V, MAP[k, v] <: GenMap[k, v]](xs: MAP[K, V])(implicit collecting: Collecting[(K, V), GenTraversable[(K, V)]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[(K, V)]
    Definition Classes
    Matchers
  27. def all[E, C[_]](xs: C[E])(implicit collecting: Collecting[E, C[E]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[E]
    Definition Classes
    Matchers
  28. def allElementsOf[R](elements: GenTraversable[R]): ResultOfAllElementsOfApplication
    Definition Classes
    Matchers
  29. def allOf(firstEle: Any, secondEle: Any, remainingEles: Any*)(implicit pos: Position): ResultOfAllOfApplication
    Definition Classes
    Matchers
  30. def an[T](implicit arg0: ClassTag[T]): ResultOfAnTypeInvocation[T]
    Definition Classes
    Matchers
  31. val an: AnWord
    Definition Classes
    Matchers
  32. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  33. macro def assert(condition: Boolean, clue: Any)(implicit prettifier: Prettifier, pos: Position): Assertion
    Definition Classes
    Assertions
  34. macro def assert(condition: Boolean)(implicit prettifier: Prettifier, pos: Position): Assertion
    Definition Classes
    Assertions
  35. macro def assertCompiles(code: String)(implicit pos: Position): Assertion
    Definition Classes
    Assertions
  36. macro def assertDoesNotCompile(code: String)(implicit pos: Position): Assertion
    Definition Classes
    Assertions
  37. def assertJobInitialized(executionGraph: AccessExecutionGraph): Assertion
    Attributes
    protected
  38. def assertResult(expected: Any)(actual: Any)(implicit prettifier: Prettifier, pos: Position): Assertion
    Definition Classes
    Assertions
  39. def assertResult(expected: Any, clue: Any)(actual: Any)(implicit prettifier: Prettifier, pos: Position): Assertion
    Definition Classes
    Assertions
  40. def assertThrows[T <: AnyRef](f: ⇒ Any)(implicit classTag: ClassTag[T], pos: Position): Assertion
    Definition Classes
    Assertions
  41. macro def assertTypeError(code: String)(implicit pos: Position): Assertion
    Definition Classes
    Assertions
  42. val assertionsHelper: AssertionsHelper
    Definition Classes
    Assertions
  43. macro def assume(condition: Boolean, clue: Any)(implicit prettifier: Prettifier, pos: Position): Assertion
    Definition Classes
    Assertions
  44. macro def assume(condition: Boolean)(implicit prettifier: Prettifier, pos: Position): Assertion
    Definition Classes
    Assertions
  45. def atLeast(num: Int, xs: String)(implicit collecting: Collecting[Char, String], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Char]
    Definition Classes
    Matchers
  46. def atLeast[K, V, JMAP[k, v] <: Map[k, v]](num: Int, xs: JMAP[K, V])(implicit collecting: Collecting[Entry[K, V], JMAP[K, V]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Entry[K, V]]
    Definition Classes
    Matchers
  47. def atLeast[K, V, MAP[k, v] <: GenMap[k, v]](num: Int, xs: MAP[K, V])(implicit collecting: Collecting[(K, V), GenTraversable[(K, V)]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[(K, V)]
    Definition Classes
    Matchers
  48. def atLeast[E, C[_]](num: Int, xs: C[E])(implicit collecting: Collecting[E, C[E]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[E]
    Definition Classes
    Matchers
  49. def atLeastOneElementOf(elements: GenTraversable[Any]): ResultOfAtLeastOneElementOfApplication
    Definition Classes
    Matchers
  50. def atLeastOneOf(firstEle: Any, secondEle: Any, remainingEles: Any*)(implicit pos: Position): ResultOfAtLeastOneOfApplication
    Definition Classes
    Matchers
  51. def atMost(num: Int, xs: String)(implicit collecting: Collecting[Char, String], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Char]
    Definition Classes
    Matchers
  52. def atMost[K, V, JMAP[k, v] <: Map[k, v]](num: Int, xs: JMAP[K, V])(implicit collecting: Collecting[Entry[K, V], JMAP[K, V]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Entry[K, V]]
    Definition Classes
    Matchers
  53. def atMost[K, V, MAP[k, v] <: GenMap[k, v]](num: Int, xs: MAP[K, V])(implicit collecting: Collecting[(K, V), GenTraversable[(K, V)]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[(K, V)]
    Definition Classes
    Matchers
  54. def atMost[E, C[_]](num: Int, xs: C[E])(implicit collecting: Collecting[E, C[E]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[E]
    Definition Classes
    Matchers
  55. def atMostOneElementOf[R](elements: GenTraversable[R]): ResultOfAtMostOneElementOfApplication
    Definition Classes
    Matchers
  56. def atMostOneOf(firstEle: Any, secondEle: Any, remainingEles: Any*)(implicit pos: Position): ResultOfAtMostOneOfApplication
    Definition Classes
    Matchers
  57. val be: BeWord
    Definition Classes
    MatcherWords
  58. def between(from: Int, upTo: Int, xs: String)(implicit collecting: Collecting[Char, String], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Char]
    Definition Classes
    Matchers
  59. def between[K, V, JMAP[k, v] <: Map[k, v]](from: Int, upTo: Int, xs: JMAP[K, V])(implicit collecting: Collecting[Entry[K, V], JMAP[K, V]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Entry[K, V]]
    Definition Classes
    Matchers
  60. def between[E, C[_]](from: Int, upTo: Int, xs: C[E])(implicit collecting: Collecting[E, C[E]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[E]
    Definition Classes
    Matchers
  61. def cancel(jobId: JobID): Unit
  62. def cancel(cause: Throwable)(implicit pos: Position): Nothing
    Definition Classes
    Assertions
  63. def cancel(message: String, cause: Throwable)(implicit pos: Position): Nothing
    Definition Classes
    Assertions
  64. def cancel(message: String)(implicit pos: Position): Nothing
    Definition Classes
    Assertions
  65. def cancel()(implicit pos: Position): Nothing
    Definition Classes
    Assertions
  66. def checkJobNotFailing(jobID: JobID): Unit
  67. def clean[F](arg0: F): F
    Definition Classes
    StreamExecutionEnvironment
  68. def cleanupGraph(): Unit
  69. def clearJobListeners(): Unit
    Definition Classes
    StreamExecutionEnvironment
  70. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  71. val compile: CompileWord
    Definition Classes
    MatcherWords
  72. def configure(arg0: ReadableConfig, arg1: ClassLoader): Unit
    Definition Classes
    StreamExecutionEnvironment
  73. def configure(arg0: ReadableConfig): Unit
    Definition Classes
    StreamExecutionEnvironment
  74. val contain: ContainWord
    Definition Classes
    MatcherWords
  75. def conversionCheckedConstraint[A, B](implicit equivalenceOfA: Equivalence[A], cnv: (B) ⇒ A): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  76. def convertEquivalenceToAToBConstraint[A, B](equivalenceOfB: Equivalence[B])(implicit ev: <:<[A, B]): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  77. def convertEquivalenceToAToBConversionConstraint[A, B](equivalenceOfB: Equivalence[B])(implicit ev: (A) ⇒ B): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  78. def convertEquivalenceToBToAConstraint[A, B](equivalenceOfA: Equivalence[A])(implicit ev: <:<[B, A]): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  79. def convertEquivalenceToBToAConversionConstraint[A, B](equivalenceOfA: Equivalence[A])(implicit ev: (B) ⇒ A): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  80. implicit def convertNumericToPlusOrMinusWrapper[T](pivot: T)(implicit arg0: Numeric[T]): PlusOrMinusWrapper[T]
    Definition Classes
    Tolerance
  81. implicit def convertSymbolToHavePropertyMatcherGenerator(symbol: Symbol)(implicit prettifier: Prettifier, pos: Position): HavePropertyMatcherGenerator
    Definition Classes
    Matchers
  82. implicit def convertToAnyShouldWrapper[T](o: T)(implicit pos: Position, prettifier: Prettifier): AnyShouldWrapper[T]
    Definition Classes
    Matchers
  83. def convertToCheckingEqualizer[T](left: T): CheckingEqualizer[T]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  84. implicit def convertToEqualizer[T](left: T): Equalizer[T]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  85. implicit def convertToRegexWrapper(o: Regex): RegexWrapper
    Definition Classes
    Matchers
  86. implicit def convertToStringShouldWrapper(o: String)(implicit pos: Position, prettifier: Prettifier): StringShouldWrapper
    Definition Classes
    Matchers
  87. implicit def convertToStringShouldWrapperForVerb(o: String)(implicit position: Position): StringShouldWrapperForVerb
    Definition Classes
    ShouldVerb
  88. def createInput[OUT](arg0: InputFormat[OUT, _], arg1: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  89. def createInput[OUT](arg0: InputFormat[OUT, _]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  90. val decided: DecidedWord
    Definition Classes
    Explicitly
  91. def defaultEquality[A]: Equality[A]
    Definition Classes
    TripleEqualsSupport
  92. val defined: DefinedWord
    Definition Classes
    MatcherWords
  93. def definedAt[T](right: T): ResultOfDefinedAt[T]
    Definition Classes
    Matchers
  94. val determined: DeterminedWord
    Definition Classes
    Explicitly
  95. def disableOperatorChaining(): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  96. val empty: EmptyWord
    Definition Classes
    MatcherWords
  97. def enableCheckpointing(arg0: Long, arg1: CheckpointingMode): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  98. def enableCheckpointing(arg0: Long): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  99. val endWith: EndWithWord
    Definition Classes
    MatcherWords
  100. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  101. def equal(o: Null): Matcher[AnyRef]
    Definition Classes
    Matchers
  102. def equal[T](spread: Spread[T]): Matcher[T]
    Definition Classes
    Matchers
  103. def equal(right: Any): MatcherFactory1[Any, Equality]
    Definition Classes
    MatcherWords
  104. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  105. def every(xs: String)(implicit collecting: Collecting[Char, String], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Char]
    Definition Classes
    Matchers
  106. def every[K, V, JMAP[k, v] <: Map[k, v]](xs: JMAP[K, V])(implicit collecting: Collecting[Entry[K, V], JMAP[K, V]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Entry[K, V]]
    Definition Classes
    Matchers
  107. def every[K, V, MAP[k, v] <: Map[k, v]](xs: MAP[K, V])(implicit collecting: Collecting[(K, V), GenTraversable[(K, V)]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[(K, V)]
    Definition Classes
    Matchers
  108. def every[E, C[_]](xs: C[E])(implicit collecting: Collecting[E, C[E]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[E]
    Definition Classes
    Matchers
  109. def exactly(num: Int, xs: String)(implicit collecting: Collecting[Char, String], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Char]
    Definition Classes
    Matchers
  110. def exactly[K, V, JMAP[k, v] <: Map[k, v]](num: Int, xs: JMAP[K, V])(implicit collecting: Collecting[Entry[K, V], JMAP[K, V]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Entry[K, V]]
    Definition Classes
    Matchers
  111. def exactly[K, V, MAP[k, v] <: GenMap[k, v]](num: Int, xs: MAP[K, V])(implicit collecting: Collecting[(K, V), GenTraversable[(K, V)]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[(K, V)]
    Definition Classes
    Matchers
  112. def exactly[E, C[_]](num: Int, xs: C[E])(implicit collecting: Collecting[E, C[E]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[E]
    Definition Classes
    Matchers
  113. def execute(streamGraph: StreamGraph): JobExecutionResult
    Definition Classes
    MiniClusterExecutionEnvironment → StreamExecutionEnvironment
  114. def execute(arg0: String): JobExecutionResult
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @throws( classOf[java.lang.Exception] )
  115. def execute(): JobExecutionResult
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @throws( classOf[java.lang.Exception] )
  116. def executeAndWaitForFinished[T](jobName: String)(patience: org.scalatest.concurrent.Eventually.PatienceConfig = ...): JobExecutionResult
  117. def executeAndWaitForStart[T](jobName: String): JobExecutionResult
  118. def executeAsync(arg0: StreamGraph): JobClient
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @throws( classOf[java.lang.Exception] )
  119. def executeAsync(arg0: String): JobClient
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @throws( classOf[java.lang.Exception] )
  120. final def executeAsync(): JobClient
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @throws( classOf[java.lang.Exception] )
  121. val exist: ExistWord
    Definition Classes
    MatcherWords
  122. def fail(cause: Throwable)(implicit pos: Position): Nothing
    Definition Classes
    Assertions
  123. def fail(message: String, cause: Throwable)(implicit pos: Position): Nothing
    Definition Classes
    Assertions
  124. def fail(message: String)(implicit pos: Position): Nothing
    Definition Classes
    Assertions
  125. def fail()(implicit pos: Position): Nothing
    Definition Classes
    Assertions
  126. def fromCollection[OUT](arg0: Iterator[OUT], arg1: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  127. def fromCollection[OUT](arg0: Iterator[OUT], arg1: Class[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  128. def fromCollection[OUT](arg0: Collection[OUT], arg1: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  129. def fromCollection[OUT](arg0: Collection[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  130. final def fromElements[OUT](arg0: Class[OUT], arg1: <repeated...>[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @transient() @SafeVarargs()
  131. final def fromElements[OUT](arg0: <repeated...>[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @transient() @SafeVarargs()
  132. def fromParallelCollection[OUT](arg0: SplittableIterator[OUT], arg1: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  133. def fromParallelCollection[OUT](arg0: SplittableIterator[OUT], arg1: Class[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  134. def fromSequence(arg0: Long, arg1: Long): DataStreamSource[Long]
    Definition Classes
    StreamExecutionEnvironment
  135. def fromSource[OUT](arg0: Source[OUT, _, _], arg1: WatermarkStrategy[OUT], arg2: String, arg3: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  136. def fromSource[OUT](arg0: Source[OUT, _, _], arg1: WatermarkStrategy[OUT], arg2: String): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  137. val fullyMatch: FullyMatchWord
    Definition Classes
    MatcherWords
  138. def generateStreamGraph(arg0: List[Transformation[_]]): StreamGraph
    Definition Classes
    StreamExecutionEnvironment
  139. def getBufferTimeout(): Long
    Definition Classes
    StreamExecutionEnvironment
  140. def getCachedFiles(): List[Tuple2[String, DistributedCacheEntry]]
    Definition Classes
    StreamExecutionEnvironment
  141. def getCheckpointConfig(): CheckpointConfig
    Definition Classes
    StreamExecutionEnvironment
  142. def getCheckpointInterval(): Long
    Definition Classes
    StreamExecutionEnvironment
  143. def getCheckpointingMode(): CheckpointingMode
    Definition Classes
    StreamExecutionEnvironment
  144. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  145. def getConfig(): ExecutionConfig
    Definition Classes
    StreamExecutionEnvironment
  146. def getConfiguration(): ReadableConfig
    Definition Classes
    StreamExecutionEnvironment
  147. def getDefaultSavepointDirectory(): Path
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Nullable()
  148. def getExecutionPlan(): String
    Definition Classes
    StreamExecutionEnvironment
  149. def getJobListeners(): List[JobListener]
    Definition Classes
    StreamExecutionEnvironment
  150. def getMaxParallelism(): Int
    Definition Classes
    StreamExecutionEnvironment
  151. def getParallelism(): Int
    Definition Classes
    StreamExecutionEnvironment
  152. def getRestartStrategy(): RestartStrategyConfiguration
    Definition Classes
    StreamExecutionEnvironment
  153. def getStateBackend(): StateBackend
    Definition Classes
    StreamExecutionEnvironment
  154. def getStreamGraph(arg0: Boolean): StreamGraph
    Definition Classes
    StreamExecutionEnvironment
  155. def getStreamGraph(): StreamGraph
    Definition Classes
    StreamExecutionEnvironment
  156. def getUserClassloader(): ClassLoader
    Attributes
    protected[environment]
    Definition Classes
    StreamExecutionEnvironment
  157. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  158. val have: HaveWord
    Definition Classes
    MatcherWords
  159. def inOrder(firstEle: Any, secondEle: Any, remainingEles: Any*)(implicit pos: Position): ResultOfInOrderApplication
    Definition Classes
    Matchers
  160. def inOrderElementsOf[R](elements: GenTraversable[R]): ResultOfInOrderElementsOfApplication
    Definition Classes
    Matchers
  161. def inOrderOnly[T](firstEle: Any, secondEle: Any, remainingEles: Any*)(implicit pos: Position): ResultOfInOrderOnlyApplication
    Definition Classes
    Matchers
  162. val include: IncludeWord
    Definition Classes
    MatcherWords
  163. def intercept[T <: AnyRef](f: ⇒ Any)(implicit classTag: ClassTag[T], pos: Position): T
    Definition Classes
    Assertions
  164. def isChainingEnabled(): Boolean
    Definition Classes
    StreamExecutionEnvironment
  165. def isForceUnalignedCheckpoints(): Boolean
    Definition Classes
    StreamExecutionEnvironment
  166. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  167. def isUnalignedCheckpointsEnabled(): Boolean
    Definition Classes
    StreamExecutionEnvironment
  168. val key: KeyWord
    Definition Classes
    Matchers
  169. val length: LengthWord
    Definition Classes
    MatcherWords
  170. lazy val logger: Logger
    Attributes
    protected
    Definition Classes
    LazyLogging
    Annotations
    @transient()
  171. def lowPriorityConversionCheckedConstraint[A, B](implicit equivalenceOfB: Equivalence[B], cnv: (A) ⇒ B): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  172. def lowPriorityTypeCheckedConstraint[A, B](implicit equivalenceOfB: Equivalence[B], ev: <:<[A, B]): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  173. val matchPattern: MatchPatternWord
    Definition Classes
    MatcherWords
  174. def message(expectedMessage: String): ResultOfMessageWordApplication
    Definition Classes
    Matchers
  175. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  176. def no(xs: String)(implicit collecting: Collecting[Char, String], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Char]
    Definition Classes
    Matchers
  177. def no[K, V, JMAP[k, v] <: Map[k, v]](xs: JMAP[K, V])(implicit collecting: Collecting[Entry[K, V], JMAP[K, V]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[Entry[K, V]]
    Definition Classes
    Matchers
  178. def no[E, C[_]](xs: C[E])(implicit collecting: Collecting[E, C[E]], prettifier: Prettifier, pos: Position): ResultOfCollectedAny[E]
    Definition Classes
    Matchers
  179. def noElementsOf(elements: GenTraversable[Any]): ResultOfNoElementsOfApplication
    Definition Classes
    Matchers
  180. def noException(implicit pos: Position): NoExceptionWord
    Definition Classes
    MatcherWords
  181. def noneOf(firstEle: Any, secondEle: Any, remainingEles: Any*)(implicit pos: Position): ResultOfNoneOfApplication
    Definition Classes
    Matchers
  182. val not: NotWord
    Definition Classes
    MatcherWords
  183. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  184. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  185. def of[T](implicit ev: ClassTag[T]): ResultOfOfTypeInvocation[T]
    Definition Classes
    Matchers
  186. def oneElementOf(elements: GenTraversable[Any]): ResultOfOneElementOfApplication
    Definition Classes
    Matchers
  187. def oneOf(firstEle: Any, secondEle: Any, remainingEles: Any*)(implicit pos: Position): ResultOfOneOfApplication
    Definition Classes
    Matchers
  188. def only(xs: Any*)(implicit pos: Position): ResultOfOnlyApplication
    Definition Classes
    Matchers
  189. def pending: Assertion with PendingStatement
    Definition Classes
    Assertions
  190. def pendingUntilFixed(f: ⇒ Unit)(implicit pos: Position): Assertion with PendingStatement
    Definition Classes
    Assertions
  191. def readFile[OUT](arg0: FileInputFormat[OUT], arg1: String, arg2: FileProcessingMode, arg3: Long, arg4: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  192. def readFile[OUT](arg0: FileInputFormat[OUT], arg1: String, arg2: FileProcessingMode, arg3: Long): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  193. def readFile[OUT](arg0: FileInputFormat[OUT], arg1: String): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
  194. def readTextFile(arg0: String, arg1: String): DataStreamSource[String]
    Definition Classes
    StreamExecutionEnvironment
  195. def readTextFile(arg0: String): DataStreamSource[String]
    Definition Classes
    StreamExecutionEnvironment
  196. val readable: ReadableWord
    Definition Classes
    MatcherWords
  197. val regex: RegexWord
    Definition Classes
    Matchers
  198. def registerCachedFile(arg0: String, arg1: String, arg2: Boolean): Unit
    Definition Classes
    StreamExecutionEnvironment
  199. def registerCachedFile(arg0: String, arg1: String): Unit
    Definition Classes
    StreamExecutionEnvironment
  200. def registerJobListener(arg0: JobListener): Unit
    Definition Classes
    StreamExecutionEnvironment
  201. def registerSlotSharingGroup(arg0: SlotSharingGroup): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  202. def registerType(arg0: Class[_]): Unit
    Definition Classes
    StreamExecutionEnvironment
  203. def registerTypeWithKryoSerializer(arg0: Class[_], arg1: Class[_ <: Serializer]): Unit
    Definition Classes
    StreamExecutionEnvironment
  204. def registerTypeWithKryoSerializer[T <: Serializer[_] with Serializable](arg0: Class[_], arg1: T): Unit
    Definition Classes
    StreamExecutionEnvironment
  205. def setBufferTimeout(arg0: Long): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  206. def setDefaultSavepointDirectory(arg0: Path): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  207. def setDefaultSavepointDirectory(arg0: URI): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  208. def setDefaultSavepointDirectory(arg0: String): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  209. def setMaxParallelism(arg0: Int): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  210. def setParallelism(arg0: Int): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  211. def setRestartStrategy(arg0: RestartStrategyConfiguration): Unit
    Definition Classes
    StreamExecutionEnvironment
  212. def setRuntimeMode(arg0: RuntimeExecutionMode): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  213. def setStateBackend(arg0: StateBackend): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
  214. val size: SizeWord
    Definition Classes
    MatcherWords
  215. def socketTextStream(arg0: String, arg1: Int): DataStreamSource[String]
    Definition Classes
    StreamExecutionEnvironment
  216. def socketTextStream(arg0: String, arg1: Int, arg2: String): DataStreamSource[String]
    Definition Classes
    StreamExecutionEnvironment
  217. def socketTextStream(arg0: String, arg1: Int, arg2: String, arg3: Long): DataStreamSource[String]
    Definition Classes
    StreamExecutionEnvironment
  218. val sorted: SortedWord
    Definition Classes
    MatcherWords
  219. val startWith: StartWithWord
    Definition Classes
    MatcherWords
  220. def stopJob[T](jobName: String, jobID: JobID): Unit
  221. def stopJob[T](jobName: String, executionResult: JobExecutionResult): Unit
  222. final val succeed: Assertion
    Definition Classes
    Assertions
  223. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  224. def the[T](implicit arg0: ClassTag[T], pos: Position): ResultOfTheTypeInvocation[T]
    Definition Classes
    Matchers
  225. def theSameElementsAs(xs: GenTraversable[_]): ResultOfTheSameElementsAsApplication
    Definition Classes
    Matchers
  226. def theSameElementsInOrderAs(xs: GenTraversable[_]): ResultOfTheSameElementsInOrderAsApplication
    Definition Classes
    Matchers
  227. val theSameInstanceAs: TheSameInstanceAsPhrase
    Definition Classes
    Matchers
  228. def thrownBy(fun: ⇒ Any): ResultOfThrownByApplication
    Definition Classes
    Matchers
  229. def toString(): String
    Definition Classes
    AnyRef → Any
  230. val typeCheck: TypeCheckWord
    Definition Classes
    MatcherWords
  231. def typeCheckedConstraint[A, B](implicit equivalenceOfA: Equivalence[A], ev: <:<[B, A]): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  232. implicit def unconstrainedEquality[A, B](implicit equalityOfA: Equality[A]): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
  233. val value: ValueWord
    Definition Classes
    Matchers
  234. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  235. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  236. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  237. def waitForJobState(jobID: JobID, name: String, expectedState: ExecutionState*)(patience: org.scalatest.concurrent.Eventually.PatienceConfig = ...): Unit
  238. def waitForStart(jobID: JobID, name: String)(patience: org.scalatest.concurrent.Eventually.PatienceConfig = ...): Unit
  239. def withClue[T](clue: Any)(fun: ⇒ T): T
    Definition Classes
    Assertions
  240. def withJobRunning[T](jobName: String, actionToInvokeWithJobRunning: (JobExecutionResult) ⇒ T): T
  241. def withJobRunning[T](jobName: String)(actionToInvokeWithJobRunning: ⇒ T): T
  242. val writable: WritableWord
    Definition Classes
    MatcherWords

Deprecated Value Members

  1. def enableCheckpointing(): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  2. def enableCheckpointing(arg0: Long, arg1: CheckpointingMode, arg2: Boolean): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  3. 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.

  4. def generateSequence(arg0: Long, arg1: Long): DataStreamSource[Long]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  5. def getNumberOfExecutionRetries(): Int
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  6. def getStreamTimeCharacteristic(): TimeCharacteristic
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  7. def isForceCheckpointing(): Boolean
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  8. def readFile[OUT](arg0: FileInputFormat[OUT], arg1: String, arg2: FileProcessingMode, arg3: Long, arg4: FilePathFilter): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  9. def readFileStream(arg0: String, arg1: Long, arg2: WatchType): DataStream[String]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  10. def setNumberOfExecutionRetries(arg0: Int): Unit
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  11. def setStreamTimeCharacteristic(arg0: TimeCharacteristic): Unit
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  12. def socketTextStream(arg0: String, arg1: Int, arg2: Char): DataStreamSource[String]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  13. def socketTextStream(arg0: String, arg1: Int, arg2: Char, arg3: Long): DataStreamSource[String]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  14. def trap[T](f: ⇒ T): Throwable
    Definition Classes
    Assertions
    Annotations
    @deprecated
    Deprecated

    The trap method is no longer needed for demos in the REPL, which now abreviates stack traces, and will be removed in a future version of ScalaTest

Inherited from Matchers

Inherited from Explicitly

Inherited from MatcherWords

Inherited from ShouldVerb

Inherited from Tolerance

Inherited from Assertions

Inherited from TripleEquals

Inherited from TripleEqualsSupport

Inherited from LazyLogging

Inherited from StreamExecutionEnvironment

Inherited from AnyRef

Inherited from Any

Ungrouped