org.apache.beam.sdk.transforms

Class GroupIntoBatches.BatchingParams<InputT>

java.lang.Object

org.apache.beam.sdk.transforms.GroupIntoBatches.BatchingParams<InputT>

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

GroupIntoBatches<K,InputT>

public abstract static class GroupIntoBatches.BatchingParams<InputT>
extends java.lang.Object
implements java.io.Serializable

Wrapper class for batching parameters supplied by users. Shared by both GroupIntoBatches and GroupIntoBatches.WithShardedKey.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BatchingParams()

Method Summary

Modifier and Type	Method and Description
static <InputT> GroupIntoBatches.BatchingParams<InputT>	create(long batchSize, long batchSizeBytes, SerializableFunction<InputT,java.lang.Long> elementByteSize, Duration maxBufferingDuration)
abstract long	getBatchSize()
abstract long	getBatchSizeBytes()
abstract SerializableFunction<InputT,java.lang.Long>	getElementByteSize()
abstract Duration	getMaxBufferingDuration()
SerializableFunction<InputT,java.lang.Long>	getWeigher(Coder<InputT> valueCoder)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BatchingParams

public BatchingParams()

Method Detail

create

public static <InputT> GroupIntoBatches.BatchingParams<InputT> create(long batchSize,
                                                                      long batchSizeBytes,
                                                                      SerializableFunction<InputT,java.lang.Long> elementByteSize,
                                                                      Duration maxBufferingDuration)

getBatchSize

public abstract long getBatchSize()

getBatchSizeBytes

public abstract long getBatchSizeBytes()

getElementByteSize

@Nullable
public abstract SerializableFunction<InputT,java.lang.Long> getElementByteSize()

getMaxBufferingDuration

public abstract Duration getMaxBufferingDuration()

getWeigher

public SerializableFunction<InputT,java.lang.Long> getWeigher(Coder<InputT> valueCoder)