Packages

class StreamBuilder extends AnyRef

Stream Builder

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. StreamBuilder
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new StreamBuilder(_transportBuilder: Option[(StreamBuilder) ⇒ StreamTransportBuilder] = None, _schemaBuilder: Option[Either[String, (StreamBuilder) ⇒ StreamSchemaRefBuilder]] = None, _batchingBuilder: Option[Either[StreamBatchingMode.Value, (StreamBuilder) ⇒ StreamBatchingBuilder]] = None, _version: String = "1.2", _description: Option[String] = None, _loop: Boolean = false, _skipTo: Option[Int] = None, _skipToRecord: Option[Either[Int, KafkaSkipToRecord.Value]] = None, _envelopeBuilder: Option[(StreamBuilder) ⇒ StreamEnvelopeBuilder] = None, _encoding: Option[StreamEncoding.Value] = None, _lingerTime: Int = 3000)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  6. def endStream(): Stream

    Build a Stream object

  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  16. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  17. def toString(): String
    Definition Classes
    AnyRef → Any
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  20. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  21. def withBatching(mode: StreamBatchingMode.Value): StreamBuilder.this.type

    Set Batching

  22. def withDescription(description: String): StreamBuilder.this.type

    Set description

  23. def withEncoding(encoding: StreamEncoding.Value): StreamBuilder

    Set encoding

  24. def withLingerTime(lingerTime: Int): StreamBuilder

    Set lingerTime

  25. def withLoop(loop: Boolean): StreamBuilder.this.type

    Set loop

  26. def withNewBatching(): StreamBatchingBuilder

    Add a new Batching parameter

  27. def withNewDelimitedEnvelope(): StreamEnvelopeDelimitedBuilder

    Add a new Delimited Envelope parameter

  28. def withNewExecTransport(): StreamTransportExecBuilder

    Add a new Exec Transport parameter

  29. def withNewFileTransport(): StreamTransportFileBuilder

    Add a new File Transport parameter

  30. def withNewFixedEnvelope(): StreamEnvelopeFixedBuilder

    Add a new Fixed Envelope parameter

  31. def withNewHTTPTransport(): StreamTransportHTTPBuilder

    Add a new HTTP Transport parameter

  32. def withNewInlineTransport(): StreamTransportInlineBuilder

    Add a new Inline Transport parameter

  33. def withNewKafkaTransport(): StreamTransportKafkaBuilder

    Add a new Kafka Transport parameter

  34. def withNewODBCTransportBuilder(): StreamTransportODBCBuilder

    Add a new ODBC Transport parameter

  35. def withNewOcfBlockEnvelope(): StreamEnvelopeOcfBlockBuilder

    Add a new Ocf Block Envelope parameter

  36. def withNewRESTTransport(): StreamTransportRESTBuilder

    Add a new REST Transport parameter

  37. def withNewSchemaRef(): StreamSchemaRefBuilder

    Add a new Schema Ref parameter

  38. def withNewTCPTransportBuilder(): StreamTransportTCPBuilder

    Add a new TCP Transport parameter

  39. def withNewUDPTransport(): StreamTransportUDPBuilder

    Add a new UDP Transport parameter

  40. def withSchema(schema: String): StreamBuilder.this.type

    Set a Schema

  41. def withSkipTo(skipTo: Int): StreamBuilder.this.type

    Set skipTo

  42. def withSkipToKafkaRecord(record: KafkaSkipToRecord.Value): StreamBuilder.this.type

    Set SkipToKafkaRecord

  43. def withSkipToRecord(recordNumber: Int): StreamBuilder.this.type

    Set skipToRecord

  44. def withTransportDiscard(): StreamBuilder.this.type

    Add a Discard Transport Parameter

  45. def withVersion(version: String): StreamBuilder.this.type

    Set version

Inherited from AnyRef

Inherited from Any

Ungrouped