Modifier and Type | Method and Description |
---|---|
java.util.Map<IngressType,SourceProvider> |
StatefulFunctionsUniverse.sources() |
Modifier and Type | Method and Description |
---|---|
void |
StatefulFunctionsUniverse.bindSourceProvider(IngressType type,
SourceProvider provider) |
Modifier and Type | Field and Description |
---|---|
static IngressType |
HarnessConstants.SUPPLYING_INGRESS_TYPE |
Modifier and Type | Method and Description |
---|---|
IngressType |
SupplyingIngressSpec.type() |
Modifier and Type | Method and Description |
---|---|
IngressType |
SourceFunctionSpec.type() |
Modifier and Type | Field and Description |
---|---|
static IngressType |
ProtobufKafkaIngressTypes.PROTOBUF_KAFKA_INGRESS_TYPE |
static IngressType |
ProtobufKafkaIngressTypes.ROUTABLE_PROTOBUF_KAFKA_INGRESS_TYPE |
Modifier and Type | Field and Description |
---|---|
static IngressType |
PolyglotKinesisIOTypes.ROUTABLE_PROTOBUF_KINESIS_INGRESS_TYPE |
Modifier and Type | Method and Description |
---|---|
IngressType |
JsonIngressSpec.type() |
Modifier and Type | Method and Description |
---|---|
void |
FlinkIoModule.Binder.bindSourceProvider(IngressType type,
SourceProvider provider) |
Constructor and Description |
---|
JsonIngressSpec(IngressType type,
IngressIdentifier<T> id,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode json) |
Modifier and Type | Method and Description |
---|---|
IngressType |
IngressSpec.type()
Returns the type of the ingress.
|
Modifier and Type | Field and Description |
---|---|
static IngressType |
Constants.KAFKA_INGRESS_TYPE |
Modifier and Type | Method and Description |
---|---|
IngressType |
KafkaIngressSpec.type() |
Modifier and Type | Field and Description |
---|---|
static IngressType |
KinesisIOTypes.UNIVERSAL_INGRESS_TYPE |
Modifier and Type | Method and Description |
---|---|
IngressType |
KinesisIngressSpec.type() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.