Package org.apache.beam.sdk.function

package org.apache.beam.sdk.function

Java 8 functional interface extensions.

Related Packages

Package	Description
org.apache.beam.sdk	Provides a simple, powerful model for building both batch and streaming parallel data processing Pipelines.

Interfaces

Class	Description
CloseableThrowingConsumer<ExceptionT extends Exception,T>	A ThrowingConsumer that can be closed.
ThrowingBiConsumer<T1,T2>	A BiConsumer which can throw Exceptions.
ThrowingBiFunction<T1,T2,T3>	A BiFunction which can throw Exceptions.
ThrowingConsumer<ExceptionT extends Exception,T>	A Consumer which can throw Exceptions.
ThrowingFunction<T1,T2>	A Function which can throw Exceptions.
ThrowingRunnable	A Runnable which can throw Exceptions.