org.apache.kafka.streams.kstream

Class Named

java.lang.Object

org.apache.kafka.streams.kstream.Named

public class Named
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected String	name

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Named(Named named)
protected	Named(String name)

Method Summary

Modifier and Type	Method and Description
static Named	as(String name) Create a Named instance with provided name.
protected static void	validate(String name)
Named	withName(String name) Sets the name to be used for an operation.

Methods inherited from class java.lang.Object

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

Field Detail

name

protected String name

Constructor Detail

Named

protected Named(Named named)

Named

protected Named(String name)

Method Detail

as

public static Named as(String name)

Create a Named instance with provided name.

Parameters:

name - the processor name to be used. If null a default processor name will be generated.

Returns:

A new Named instance configured with name

Throws:

TopologyException - if an invalid name is specified; valid characters are ASCII alphanumerics, '.', '_' and '-'.

withName

public Named withName(String name)

Sets the name to be used for an operation.

Parameters:

name - the name to use.

Returns:

an instance of NamedOperation

validate

protected static void validate(String name)