class SortMergeTransformWriteBuilder[KeyType, R, W] extends Serializable
- Alphabetic
- By Inheritance
- SortMergeTransformWriteBuilder
- Serializable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SortMergeTransformWriteBuilder(transform: AbsCoGbkTransform[KeyType, W], toR: (CoGbkResult) => R)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def via(transformFn: (KeyType, R, SerializableConsumer[W]) => Unit): ClosedTap[Nothing]
Defines the transforming function applied to each key group, where the output(s) are sent to the provided consumer via its
acceptfunction.Defines the transforming function applied to each key group, where the output(s) are sent to the provided consumer via its
acceptfunction.The key group is defined as a key K and records R, where R represents the unpacked CoGbkResult converted to Scala Iterables. Note that, unless a org.apache.beam.sdk.extensions.smb.SortedBucketSource.Predicate is provided to the PTransform, the Scala Iterable is backed by a lazy iterator, and will only materialize if .toList or similar function is used in the transformFn. If you have extremely large key groups, take care to only materialize as much of the Iterable as is needed.
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def withSideInputs(sides: SideInput[_]*): SortMergeTransformWithSideInputsWriteBuilder[KeyType, R, W]