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

Deprecated Value Members

  1. def addDefaultKryoSerializer(arg0: Class[_], arg1: Class[_ <: Serializer[_]]): Unit
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  2. def addDefaultKryoSerializer[T <: Serializer[_] with Serializable](arg0: Class[_], arg1: T): Unit
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  3. def addSource[OUT](arg0: SourceFunction[OUT], arg1: String, arg2: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  4. def addSource[OUT](arg0: SourceFunction[OUT], arg1: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  5. def addSource[OUT](arg0: SourceFunction[OUT], arg1: String): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  6. def addSource[OUT](arg0: SourceFunction[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  7. def conversionCheckedConstraint[A, B](implicit equivalenceOfA: Equivalence[A], cnv: (B) ⇒ A): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
    Annotations
    @deprecated
    Deprecated

    (Since version 3.1.0) The conversionCheckedConstraint method has been deprecated and will be removed in a future version of ScalaTest. It is no longer needed now that the deprecation period of ConversionCheckedTripleEquals has expired. It will not be replaced.

  8. def convertEquivalenceToAToBConversionConstraint[A, B](equivalenceOfB: Equivalence[B])(implicit ev: (A) ⇒ B): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
    Annotations
    @deprecated
    Deprecated

    (Since version 3.1.0) The convertEquivalenceToAToBConversionConstraint method has been deprecated and will be removed in a future version of ScalaTest. It is no longer needed now that the deprecation period of ConversionCheckedTripleEquals has expired. It will not be replaced.

  9. def convertEquivalenceToBToAConversionConstraint[A, B](equivalenceOfA: Equivalence[A])(implicit ev: (B) ⇒ A): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
    Annotations
    @deprecated
    Deprecated

    (Since version 3.1.0) The convertEquivalenceToBToAConversionConstraint method has been deprecated and will be removed in a future version of ScalaTest. It is no longer needed now that the deprecation period of ConversionCheckedTripleEquals has expired. It will not be replaced.

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

    (Since version ) see corresponding Javadoc for more information.

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

    (Since version ) see corresponding Javadoc for more information.

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

  13. def fromCollection[OUT](arg0: Iterator[OUT], arg1: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  14. def fromCollection[OUT](arg0: Iterator[OUT], arg1: Class[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  15. def fromCollection[OUT](arg0: Collection[OUT], arg1: TypeInformation[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  16. def fromCollection[OUT](arg0: Collection[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  17. final def fromElements[OUT](arg0: Class[OUT], arg1: <repeated...>[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @transient() @Deprecated @SafeVarargs() @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  18. final def fromElements[OUT](arg0: <repeated...>[OUT]): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @transient() @Deprecated @SafeVarargs() @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

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

    (Since version ) see corresponding Javadoc for more information.

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

    (Since version ) see corresponding Javadoc for more information.

  21. def getRestartStrategy(): RestartStrategyConfiguration
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  22. def getStateBackend(): StateBackend
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

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

    (Since version ) see corresponding Javadoc for more information.

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

    (Since version ) see corresponding Javadoc for more information.

  25. def lowPriorityConversionCheckedConstraint[A, B](implicit equivalenceOfB: Equivalence[B], cnv: (A) ⇒ B): CanEqual[A, B]
    Definition Classes
    TripleEquals → TripleEqualsSupport
    Annotations
    @deprecated
    Deprecated

    (Since version 3.1.0) The lowPriorityConversionCheckedConstraint method has been deprecated and will be removed in a future version of ScalaTest. It is no longer needed now that the deprecation period of ConversionCheckedTripleEquals has expired. It will not be replaced.

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

    (Since version ) see corresponding Javadoc for more information.

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

    (Since version ) see corresponding Javadoc for more information.

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

  29. def readFile[OUT](arg0: FileInputFormat[OUT], arg1: String): DataStreamSource[OUT]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

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

  31. def readTextFile(arg0: String, arg1: String): DataStreamSource[String]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  32. def readTextFile(arg0: String): DataStreamSource[String]
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  33. def registerType(arg0: Class[_]): Unit
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  34. def registerTypeWithKryoSerializer(arg0: Class[_], arg1: Class[_ <: Serializer]): Unit
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  35. def registerTypeWithKryoSerializer[T <: Serializer[_] with Serializable](arg0: Class[_], arg1: T): Unit
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

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

    (Since version ) see corresponding Javadoc for more information.

  37. def setRestartStrategy(arg0: RestartStrategyConfiguration): Unit
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

  38. def setStateBackend(arg0: StateBackend): StreamExecutionEnvironment
    Definition Classes
    StreamExecutionEnvironment
    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

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

    (Since version ) see corresponding Javadoc for more information.

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

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

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 AutoCloseable

Inherited from AnyRef

Inherited from Any

Ungrouped