Package org.apache.beam.runners.twister2.translators.functions.internal

Class SystemReduceFnBuffering<K,T,W extends BoundedWindow>

java.lang.Object

org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W>

org.apache.beam.runners.core.SystemReduceFn<K,T,Iterable<T>,Iterable<T>,W>

org.apache.beam.runners.twister2.translators.functions.internal.SystemReduceFnBuffering<K,T,W>

All Implemented Interfaces:

Serializable

public class SystemReduceFnBuffering<K,T,W extends BoundedWindow>
extends org.apache.beam.runners.core.SystemReduceFn<K,T,Iterable<T>,Iterable<T>,W>

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.runners.core.ReduceFn

org.apache.beam.runners.core.ReduceFn.Context, org.apache.beam.runners.core.ReduceFn.OnMergeContext, org.apache.beam.runners.core.ReduceFn.OnTriggerContext, org.apache.beam.runners.core.ReduceFn.ProcessValueContext

Constructor Summary

Constructors

Constructor	Description
SystemReduceFnBuffering()
SystemReduceFnBuffering(Coder<T> valueCoder)

Method Summary

Modifier and Type	Method	Description
void	clearState(org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W>.org.apache.beam.runners.core.ReduceFn.Context c)
ReadableState<Boolean>	isEmpty(org.apache.beam.runners.core.StateAccessor<K> state)
void	onMerge(org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W>.org.apache.beam.runners.core.ReduceFn.OnMergeContext context)
void	onTrigger(org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W>.org.apache.beam.runners.core.ReduceFn.OnTriggerContext c)
void	prefetchOnMerge(org.apache.beam.runners.core.MergingStateAccessor<K,W> state)
void	prefetchOnTrigger(org.apache.beam.runners.core.StateAccessor<K> state)
void	processValue(org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W>.org.apache.beam.runners.core.ReduceFn.ProcessValueContext c)
protected Object	readResolve()

Methods inherited from class org.apache.beam.runners.core.SystemReduceFn

buffering, combining

Methods inherited from class java.lang.Object

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

Constructor Details

SystemReduceFnBuffering

public SystemReduceFnBuffering()

SystemReduceFnBuffering

public SystemReduceFnBuffering(Coder<T> valueCoder)

Method Details

onMerge

public void onMerge(org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W>.org.apache.beam.runners.core.ReduceFn.OnMergeContext context)
             throws Exception

Specified by:

onMerge in class org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W extends BoundedWindow>

Throws:

Exception

prefetchOnMerge

public void prefetchOnMerge(org.apache.beam.runners.core.MergingStateAccessor<K,W> state)
                     throws Exception

Overrides:

prefetchOnMerge in class org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W extends BoundedWindow>

Throws:

Exception

processValue

public void processValue(org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W>.org.apache.beam.runners.core.ReduceFn.ProcessValueContext c)
                  throws Exception

Overrides:

processValue in class org.apache.beam.runners.core.SystemReduceFn<K,T,Iterable<T>,Iterable<T>,W extends BoundedWindow>

Throws:

Exception

prefetchOnTrigger

public void prefetchOnTrigger(org.apache.beam.runners.core.StateAccessor<K> state)

Overrides:

prefetchOnTrigger in class org.apache.beam.runners.core.SystemReduceFn<K,T,Iterable<T>,Iterable<T>,W extends BoundedWindow>

onTrigger

public void onTrigger(org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W>.org.apache.beam.runners.core.ReduceFn.OnTriggerContext c)
               throws Exception

Overrides:

onTrigger in class org.apache.beam.runners.core.SystemReduceFn<K,T,Iterable<T>,Iterable<T>,W extends BoundedWindow>

Throws:

Exception

clearState

public void clearState(org.apache.beam.runners.core.ReduceFn<K,T,Iterable<T>,W>.org.apache.beam.runners.core.ReduceFn.Context c)
                throws Exception

Overrides:

clearState in class org.apache.beam.runners.core.SystemReduceFn<K,T,Iterable<T>,Iterable<T>,W extends BoundedWindow>

Throws:

Exception

isEmpty

public ReadableState<Boolean> isEmpty(org.apache.beam.runners.core.StateAccessor<K> state)

Overrides:

isEmpty in class org.apache.beam.runners.core.SystemReduceFn<K,T,Iterable<T>,Iterable<T>,W extends BoundedWindow>

readResolve

protected Object readResolve()
                      throws ObjectStreamException

Throws:

ObjectStreamException