public static class FetchInput.Builder
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
RetryPolicy |
retryPolicy |
Constructor and Description |
---|
Builder(java.lang.String id) |
Modifier and Type | Method and Description |
---|---|
FetchInput |
build() |
FetchInput.Builder |
fields(java.util.function.Consumer<MapBuilder> consumer)
Accepts a
MapBuilder consumer. |
FetchInput.Builder |
metadata(java.util.function.Consumer<MapBuilder> consumer)
Accepts a
MapBuilder consumer. |
FetchInput.Builder |
withAffinityKey(java.lang.String affinityKey) |
FetchInput.Builder |
withCanonicalId(java.lang.String value) |
FetchInput.Builder |
withFields(java.util.Map<java.lang.String,java.lang.Object> fields)
Deprecated.
replaced by
fields(Consumer) |
FetchInput.Builder |
withIsLeafNode(boolean value) |
FetchInput.Builder |
withIsTransient(boolean isTransient) |
FetchInput.Builder |
withMetadata(java.util.Map<java.lang.String,java.lang.Object> metadata)
Deprecated.
replaced by
metadata(Consumer) |
FetchInput.Builder |
withParentId(java.lang.String value) |
FetchInput.Builder |
withRetryProperties(java.util.function.Consumer<RetryPolicy> retryPropertiesConsumer) |
FetchInput.Builder |
withRetryProperties(RetryPolicy retryPolicy) |
FetchInput.Builder |
withSourcePhase(java.lang.String value) |
FetchInput.Builder |
withTargetPhase(java.lang.String value) |
public RetryPolicy retryPolicy
public FetchInput build()
public FetchInput.Builder withIsLeafNode(boolean value)
public FetchInput.Builder withAffinityKey(java.lang.String affinityKey)
@Deprecated public FetchInput.Builder withMetadata(java.util.Map<java.lang.String,java.lang.Object> metadata)
metadata(Consumer)
metadata
- metadata map@Deprecated public FetchInput.Builder withFields(java.util.Map<java.lang.String,java.lang.Object> fields)
fields(Consumer)
fields
- fields mappublic FetchInput.Builder withCanonicalId(java.lang.String value)
public FetchInput.Builder withParentId(java.lang.String value)
public FetchInput.Builder withSourcePhase(java.lang.String value)
public FetchInput.Builder withTargetPhase(java.lang.String value)
public FetchInput.Builder withIsTransient(boolean isTransient)
public FetchInput.Builder metadata(java.util.function.Consumer<MapBuilder> consumer)
MapBuilder
consumer.
e.g. FetchInput.builder("id")
.metadata(m -> {
m.setLong(“long_value”, 123l);
m.setString(“str_value”, “test”)
m.merge(Collections.singletonMap("id",123));
})
.build();
consumer
- the consumer that accepts a MapBuilder
object which sets only allowed values in map object.public FetchInput.Builder fields(java.util.function.Consumer<MapBuilder> consumer)
MapBuilder
consumer.
e.g. FetchInput.builder("id")
.fields(f -> {
f.setLong(“long_value”, 123l);
f.setString(“str_value”, “test”)
f.merge(Collections.singletonMap("id",123));
})
.build();
consumer
- the consumer that accepts a MapBuilder
object and sets only allowed values in map object.public FetchInput.Builder withRetryProperties(java.util.function.Consumer<RetryPolicy> retryPropertiesConsumer)
public FetchInput.Builder withRetryProperties(RetryPolicy retryPolicy)