Package org.apache.ignite.table

Class ReceiverDescriptor<A>

java.lang.Object

org.apache.ignite.table.ReceiverDescriptor<A>

public class ReceiverDescriptor<A>
extends Object

Data streamer receiver descriptor.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ReceiverDescriptor.Builder<A>	Builder.

Method Summary

Modifier and Type	Method	Description
@Nullable Marshaller<A,byte[]>	argumentMarshaller()
static <A> ReceiverDescriptor.Builder<A>	builder(Class<? extends DataStreamerReceiver<?,A,?>> receiverClass)	Create a new builder.
static <A> ReceiverDescriptor.Builder<A>	builder(String receiverClassName)	Create a new builder.
String	receiverClassName()	Streamer receiver class name.
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.

builder

public static <A> ReceiverDescriptor.Builder<A> builder(String receiverClassName)

Create a new builder.

Returns:

Receiver descriptor builder.

builder

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

Create a new builder.

Returns:

Receiver descriptor builder.

argumentMarshaller

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