Package org.apache.ignite.table

Class DataStreamerReceiverDescriptor.Builder<T,A,R>

java.lang.Object

org.apache.ignite.table.DataStreamerReceiverDescriptor.Builder<T,A,R>

Enclosing class:

DataStreamerReceiverDescriptor<T,A,R>

public static class DataStreamerReceiverDescriptor.Builder<T,A,R>
extends Object

Builder.

Method Summary

Modifier and Type	Method	Description
DataStreamerReceiverDescriptor.Builder<T,A,R>	argumentMarshaller(@Nullable Marshaller<A,byte[]> argumentMarshaller)	Sets the argument marshaller.
DataStreamerReceiverDescriptor<T,A,R>	build()	Builds the receiver descriptor.
DataStreamerReceiverDescriptor.Builder<T,A,R>	options(ReceiverExecutionOptions options)	Sets the receiver execution options.
DataStreamerReceiverDescriptor.Builder<T,A,R>	payloadMarshaller(@Nullable Marshaller<T,byte[]> payloadMarshaller)	Sets the payload marshaller.
DataStreamerReceiverDescriptor.Builder<T,A,R>	resultMarshaller(@Nullable Marshaller<R,byte[]> resultMarshaller)	Sets the result marshaller.
DataStreamerReceiverDescriptor.Builder<T,A,R>	units(List<DeploymentUnit> units)	Sets the deployment units.
DataStreamerReceiverDescriptor.Builder<T,A,R>	units(DeploymentUnit... units)	Sets the deployment units.

Methods inherited from class java.lang.Object

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

Method Details

units

public DataStreamerReceiverDescriptor.Builder<T,A,R> units(List<DeploymentUnit> units)

Sets the deployment units.

Parameters:

units - Deployment units.

Returns:

This builder.

units

public DataStreamerReceiverDescriptor.Builder<T,A,R> units(DeploymentUnit... units)

Sets the deployment units.

Parameters:

units - Deployment units.

Returns:

This builder.

options

public DataStreamerReceiverDescriptor.Builder<T,A,R> options(ReceiverExecutionOptions options)

Sets the receiver execution options.

Parameters:

options - Receiver execution options.

Returns:

This builder.

payloadMarshaller

public DataStreamerReceiverDescriptor.Builder<T,A,R> payloadMarshaller(@Nullable
 @Nullable Marshaller<T,byte[]> payloadMarshaller)

Sets the payload marshaller.

Parameters:

payloadMarshaller - Payload marshaller.

Returns:

This builder.

argumentMarshaller

public DataStreamerReceiverDescriptor.Builder<T,A,R> argumentMarshaller(@Nullable
 @Nullable Marshaller<A,byte[]> argumentMarshaller)

Sets the argument marshaller.

Parameters:

argumentMarshaller - Argument marshaller.

Returns:

This builder.

resultMarshaller

public DataStreamerReceiverDescriptor.Builder<T,A,R> resultMarshaller(@Nullable
 @Nullable Marshaller<R,byte[]> resultMarshaller)

Sets the result marshaller.

Parameters:

resultMarshaller - Result marshaller.

Returns:

This builder.

build

public DataStreamerReceiverDescriptor<T,A,R> build()

Builds the receiver descriptor.

Returns:

Receiver descriptor.