Package org.apache.beam.sdk.transforms

Class GroupIntoBatches.BatchingParams<InputT>

java.lang.Object

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

All Implemented Interfaces:

Serializable

Enclosing class:

GroupIntoBatches<K,InputT>

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

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

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
BatchingParams()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

BatchingParams

public BatchingParams()

Method Details

createDefault

public static <InputT>
GroupIntoBatches.BatchingParams<InputT> createDefault()

create

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

getBatchSize

public abstract long getBatchSize()

getBatchSizeBytes

public abstract long getBatchSizeBytes()

getElementByteSize

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

getMaxBufferingDuration

public abstract Duration getMaxBufferingDuration()

getWeigher

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