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>
Builder.
-
Method Summary
Modifier and TypeMethodDescriptionargumentMarshaller(@Nullable Marshaller<A, byte[]> argumentMarshaller) Sets the argument marshaller.build()Builds the receiver descriptor.options(ReceiverExecutionOptions options) Sets the receiver execution options.payloadMarshaller(@Nullable Marshaller<T, byte[]> payloadMarshaller) Sets the payload marshaller.resultMarshaller(@Nullable Marshaller<R, byte[]> resultMarshaller) Sets the result marshaller.units(List<DeploymentUnit> units) Sets the deployment units.units(DeploymentUnit... units) Sets the deployment units.
-
Method Details
-
units
Sets the deployment units.- Parameters:
units- Deployment units.- Returns:
- This builder.
-
units
Sets the deployment units.- Parameters:
units- Deployment units.- Returns:
- This builder.
-
options
Sets the receiver execution options.- Parameters:
options- Receiver execution options.- Returns:
- This builder.
-
payloadMarshaller
public DataStreamerReceiverDescriptor.Builder<T,A, payloadMarshallerR> (@Nullable @Nullable Marshaller<T, byte[]> payloadMarshaller) Sets the payload marshaller.- Parameters:
payloadMarshaller- Payload marshaller.- Returns:
- This builder.
-
argumentMarshaller
public DataStreamerReceiverDescriptor.Builder<T,A, argumentMarshallerR> (@Nullable @Nullable Marshaller<A, byte[]> argumentMarshaller) Sets the argument marshaller.- Parameters:
argumentMarshaller- Argument marshaller.- Returns:
- This builder.
-
resultMarshaller
public DataStreamerReceiverDescriptor.Builder<T,A, resultMarshallerR> (@Nullable @Nullable Marshaller<R, byte[]> resultMarshaller) Sets the result marshaller.- Parameters:
resultMarshaller- Result marshaller.- Returns:
- This builder.
-
build
Builds the receiver descriptor.- Returns:
- Receiver descriptor.
-