Package org.apache.ignite.table

Class DataStreamerReceiverDescriptor<T,A,R>

java.lang.Object

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

public class DataStreamerReceiverDescriptor<T,A,R>
extends Object

Data streamer receiver descriptor.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DataStreamerReceiverDescriptor.Builder<T,A,R>	Builder.

Method Summary

Modifier and Type	Method	Description
@Nullable Marshaller<A,byte[]>	argumentMarshaller()	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>	builder(String receiverClassName)	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.
ReceiverExecutionOptions	options()	Receiver execution options.
@Nullable Marshaller<T,byte[]>	payloadMarshaller()	Payload marshaller.
String	receiverClassName()	Streamer receiver class name.
@Nullable Marshaller<R,byte[]>	resultMarshaller()	Result marshaller.
List<DeploymentUnit>	units()	Deployment units.

Methods inherited from class java.lang.Object

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

Method Details

receiverClassName

public String receiverClassName()

Streamer receiver class name.

Returns:

Streamer receiver class name.

units

public List<DeploymentUnit> units()

Deployment units.

Returns:

Deployment units.

options

public ReceiverExecutionOptions options()

Receiver execution options.

Returns:

Receiver execution options.

payloadMarshaller

@Nullable
public @Nullable Marshaller<T,byte[]> payloadMarshaller()

Payload marshaller.

Returns:

Payload marshaller.

argumentMarshaller

@Nullable
public @Nullable Marshaller<A,byte[]> argumentMarshaller()

Argument marshaller.

Returns:

Argument marshaller.

resultMarshaller

@Nullable
public @Nullable Marshaller<R,byte[]> resultMarshaller()

Result marshaller.

Returns:

Result marshaller.

builder

public static <T,
A,
R>
DataStreamerReceiverDescriptor.Builder<T,A,R> builder(String receiverClassName)

Create a new builder.

Returns:

Receiver descriptor builder.

builder

public static <T,
A,
R>
DataStreamerReceiverDescriptor.Builder<T,A,R> builder(Class<? extends DataStreamerReceiver<T,A,R>> receiverClass)

Create a new builder.

Returns:

Receiver descriptor builder.

builder

public static <T,
A,
R>
DataStreamerReceiverDescriptor.Builder<T,A,R> builder(DataStreamerReceiver<T,A,R> receiver)

Create a new builder from a receiver instance. Populates payloadMarshaller(), argumentMarshaller(), and resultMarshaller() from the provided receiver.

Returns:

Receiver descriptor builder.