Package org.apache.ignite.table
Class DataStreamerReceiverDescriptor<T,A,R>
java.lang.Object
org.apache.ignite.table.DataStreamerReceiverDescriptor<T,A,R>
Data streamer receiver descriptor.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classBuilder. -
Method Summary
Modifier and TypeMethodDescription@Nullable Marshaller<A,byte[]> Argument marshaller.static <T,A, R> DataStreamerReceiverDescriptor.Builder<T, A, R> builder(Class<? extends DataStreamerReceiver<T, A, R>> receiverClass) Create a new builder.static <T,A, R> DataStreamerReceiverDescriptor.Builder<T, A, R> Create a new builder.static <T,A, R> DataStreamerReceiverDescriptor.Builder<T, A, R> builder(DataStreamerReceiver<T, A, R> receiver) Create a new builder from a receiver instance.options()Receiver execution options.@Nullable Marshaller<T,byte[]> Payload marshaller.Streamer receiver class name.@Nullable Marshaller<R,byte[]> Result marshaller.units()Deployment units.
-
Method Details
-
receiverClassName
Streamer receiver class name.- Returns:
- Streamer receiver class name.
-
units
Deployment units.- Returns:
- Deployment units.
-
options
Receiver execution options.- Returns:
- Receiver execution options.
-
payloadMarshaller
Payload marshaller.- Returns:
- Payload marshaller.
-
argumentMarshaller
Argument marshaller.- Returns:
- Argument marshaller.
-
resultMarshaller
Result marshaller.- Returns:
- Result marshaller.
-
builder
public static <T,A, DataStreamerReceiverDescriptor.Builder<T,R> A, builderR> (String receiverClassName) Create a new builder.- Returns:
- Receiver descriptor builder.
-
builder
public static <T,A, DataStreamerReceiverDescriptor.Builder<T,R> A, builderR> (Class<? extends DataStreamerReceiver<T, A, R>> receiverClass) Create a new builder.- Returns:
- Receiver descriptor builder.
-
builder
public static <T,A, DataStreamerReceiverDescriptor.Builder<T,R> A, builderR> (DataStreamerReceiver<T, A, R> receiver) Create a new builder from a receiver instance. PopulatespayloadMarshaller(),argumentMarshaller(), andresultMarshaller()from the provided receiver.- Returns:
- Receiver descriptor builder.
-