Index (Volt Stream Connectors 1.0.0 API)

A B C D E F G H I J K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractVoltStreamSinkConfigurator<T,S> - Class in org.voltdb.stream.api.volt
AbstractVoltStreamSinkConfigurator() - Constructor for class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator
accepting(Class<P>) - Static method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
accepting(Class<P>) - Method in class org.voltdb.stream.api.KafkaSinks
aConsumer() - Static method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
aSink() - Static method in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
aSink() - Static method in class org.voltdb.stream.api.volt.ProcedureVoltStreamSinkConfigurator
atRate(double) - Method in class org.voltdb.stream.api.util.RateLimitedSourceConfigurator
Avro - Class in org.voltdb.stream.api.volt.helper
Avro() - Constructor for class org.voltdb.stream.api.volt.helper.Avro
AVRO - Enum constant in enum class org.voltdb.stream.api.kafka.StandardEncoding
Avro.DeserializerConfigurator - Class in org.voltdb.stream.api.volt.helper
AvroToVoltProcedureParameter - Class in org.voltdb.stream.api.volt.helper
AvroToVoltProcedureParameter() - Constructor for class org.voltdb.stream.api.volt.helper.AvroToVoltProcedureParameter
AvroToVoltProcedureParameter.SerializerConfigurator - Class in org.voltdb.stream.api.volt.helper

B

build() - Method in class org.voltdb.stream.api.kafka.Headers.Builder
build() - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
builder() - Static method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration
Builder() - Constructor for class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
BulkVoltStreamSinkConfigurator - Class in org.voltdb.stream.api.volt
BulkVoltStreamSinkConfigurator() - Constructor for class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
BulkVoltStreamSinkConfigurator(int, int, String) - Constructor for class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator

C

clearHeaders() - Method in class org.voltdb.stream.api.kafka.Headers.Builder: Clears the value of the 'headers' field.
collection() - Static method in class org.voltdb.stream.api.Sinks
collection(T...) - Static method in class org.voltdb.stream.api.Sources
configure(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator: configures the configurator using custom config path.
configure(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator: configures the configurator using custom config path.
configureConverter() - Static method in class org.voltdb.stream.api.volt.helper.KafkaToVoltProcedureParameter
configureDeserializer() - Static method in class org.voltdb.stream.api.volt.helper.Avro
configureSerializer() - Static method in class org.voltdb.stream.api.volt.helper.AvroToVoltProcedureParameter
consume(Consumer<T>) - Static method in class org.voltdb.stream.api.Sinks
createDecoder(SchemaStore) - Static method in class org.voltdb.stream.api.kafka.Headers: Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.
CSV - Enum constant in enum class org.voltdb.stream.api.kafka.StandardEncoding
customDecode(ResolvingDecoder) - Method in class org.voltdb.stream.api.kafka.Headers
customEncode(Encoder) - Method in class org.voltdb.stream.api.kafka.Headers

D

DEFAULT_HOST - Static variable in class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator
DEFAULT_PROCEDURE_NAME - Static variable in class org.voltdb.stream.api.volt.ProcedureVoltStreamSinkConfigurator
DEFAULT_SINK_HOST - Static variable in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
DEFAULT_TABLE_NAME - Static variable in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
DEFAULT_TRUSTSTORE_FILE - Static variable in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration
DEFAULT_TRUSTSTORE_PASSWORD - Static variable in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration
directory(String) - Static method in class org.voltdb.stream.api.Sinks

E

EARLIEST - Enum constant in enum class org.voltdb.stream.api.kafka.KafkaStartingOffset
emptyToNull(String) - Method in class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator

F

FLUSH_INTERVAL - Static variable in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
FLUSH_INTERVAL - Static variable in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
fromByteBuffer(ByteBuffer) - Static method in class org.voltdb.stream.api.kafka.Headers: Deserializes a Headers from a ByteBuffer.
fromHostPortProperties(String, String) - Method in class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator

G

generate(Supplier<I>) - Static method in class org.voltdb.stream.api.Sources
generateAtRate(double, Supplier<I>) - Static method in class org.voltdb.stream.api.Sources
get(int) - Method in class org.voltdb.stream.api.kafka.Headers
getBatchSize() - Method in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
getClassSchema() - Static method in class org.voltdb.stream.api.kafka.Headers
getDecoder() - Static method in class org.voltdb.stream.api.kafka.Headers: Return the BinaryMessageDecoder instance used by this class.
getEncoder() - Static method in class org.voltdb.stream.api.kafka.Headers: Return the BinaryMessageEncoder instance used by this class.
getExceptionHandler() - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
getExceptionHandler() - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
getExceptionHandler() - Method in class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator
getExceptionHandler() - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
getFlushInterval() - Method in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
getFlushInterval() - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
getGroupId() - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
getHeaders() - Method in class org.voltdb.stream.api.kafka.Headers.Builder: Gets the value of the 'headers' field.
getHeaders() - Method in class org.voltdb.stream.api.kafka.Headers: Gets the value of the 'headers' field.
getHeaders() - Method in interface org.voltdb.stream.api.kafka.KafkaRequest
getHostAndPorts() - Method in class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator
getKey() - Method in interface org.voltdb.stream.api.kafka.KafkaRequest
getMaxBatchSize() - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
getMaxCommitRetries() - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
getMaxCommitTimeout() - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
getOperationType() - Method in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
getProcedureName() - Method in class org.voltdb.stream.api.volt.ProcedureVoltStreamSinkConfigurator
getProperties() - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration
getProtocolName() - Method in enum class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.TLSProtocols
getRemoteBufferName() - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
getRemoteProcedureName() - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
getRemoteTopicName() - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
getRetries() - Method in class org.voltdb.stream.api.volt.ProcedureVoltStreamSinkConfigurator
getRetries() - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
getSchema() - Method in class org.voltdb.stream.api.kafka.Headers
getSchemaRegistryUrl() - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
getSpecificData() - Method in class org.voltdb.stream.api.kafka.Headers
getSupplier() - Method in class org.voltdb.stream.api.util.RateLimitedSourceConfigurator
getTableName() - Method in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
getTopicsHostAndPorts() - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
getTps() - Method in class org.voltdb.stream.api.util.RateLimitedSourceConfigurator
getValue() - Method in interface org.voltdb.stream.api.kafka.KafkaRequest
getVoltClientHostAndPorts() - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator

H

handle(KafkaConsumer<Object, Object>, ExecutionContext, Exception) - Method in interface org.voltdb.stream.api.kafka.KafkaSourceExceptionHandler
hasCustomCoders() - Method in class org.voltdb.stream.api.kafka.Headers
hasHeaders() - Method in class org.voltdb.stream.api.kafka.Headers.Builder: Checks whether the 'headers' field has been set.
Headers - Class in org.voltdb.stream.api.kafka
Headers() - Constructor for class org.voltdb.stream.api.kafka.Headers: Default constructor.
Headers(Map<String, String>) - Constructor for class org.voltdb.stream.api.kafka.Headers: All-args constructor.
Headers.Builder - Class in org.voltdb.stream.api.kafka: RecordBuilder for Headers instances.

I

identity() - Static method in class org.voltdb.stream.api.VoltFunctions
INSERT - Enum constant in enum class org.voltdb.stream.api.volt.VoltBulkOperationType
isUpsert() - Method in enum class org.voltdb.stream.api.volt.VoltBulkOperationType

J

JSON - Enum constant in enum class org.voltdb.stream.api.kafka.StandardEncoding

K

kafka() - Static method in class org.voltdb.stream.api.Sinks
kafka() - Static method in class org.voltdb.stream.api.Sources
KafkaRequest<K,V> - Interface in org.voltdb.stream.api.kafka: this interface exposes key, value and headers of kafka message consumed from broker.
KafkaSinks - Class in org.voltdb.stream.api
KafkaSinks() - Constructor for class org.voltdb.stream.api.KafkaSinks
KafkaSourceExceptionHandler - Interface in org.voltdb.stream.api.kafka: This handler handles only errors of the poll step, this can be any of consumer misconfiguration, timeout exception, deserialization exception.
KafkaStartingOffset - Enum Class in org.voltdb.stream.api.kafka
KafkaStreamSinkConfigurator<T> - Class in org.voltdb.stream.api.kafka: this configurator can be autoconfigured using helm's values under streaming.pipeline.configuration.
KafkaStreamSourceConfigurator<K,V> - Class in org.voltdb.stream.api.kafka: this configurator can be autoconfigured using helm's values under streaming.pipeline.configuration.
KafkaStreamSslConfiguration - Class in org.voltdb.stream.api.kafka
KafkaStreamSslConfiguration.Builder - Class in org.voltdb.stream.api.kafka
KafkaStreamSslConfiguration.TLSProtocols - Enum Class in org.voltdb.stream.api.kafka
KafkaToVoltProcedureParameter - Class in org.voltdb.stream.api.volt.helper
KafkaToVoltProcedureParameter() - Constructor for class org.voltdb.stream.api.volt.helper.KafkaToVoltProcedureParameter
KafkaToVoltProcedureParameter.Configurator<K,V> - Class in org.voltdb.stream.api.volt.helper

L

LATEST - Enum constant in enum class org.voltdb.stream.api.kafka.KafkaStartingOffset

M

MAX_BATCH_SIZE - Static variable in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
MAX_BATCH_SIZE - Static variable in class org.voltdb.stream.api.volt.VoltProcedureConfigurator

N

newBuilder() - Static method in class org.voltdb.stream.api.kafka.Headers: Creates a new Headers RecordBuilder.
newBuilder(Headers) - Static method in class org.voltdb.stream.api.kafka.Headers: Creates a new Headers RecordBuilder by copying an existing Headers instance.
newBuilder(Headers.Builder) - Static method in class org.voltdb.stream.api.kafka.Headers: Creates a new Headers RecordBuilder by copying an existing Builder.
NONE - Enum constant in enum class org.voltdb.stream.api.kafka.KafkaStartingOffset

O

org.voltdb.stream.api - package org.voltdb.stream.api
org.voltdb.stream.api.kafka - package org.voltdb.stream.api.kafka
org.voltdb.stream.api.util - package org.voltdb.stream.api.util
org.voltdb.stream.api.volt - package org.voltdb.stream.api.volt
org.voltdb.stream.api.volt.helper - package org.voltdb.stream.api.volt.helper

P

procedureCall() - Method in class org.voltdb.stream.api.VoltSinks
procedureCall(String) - Static method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
procedureCall(String) - Static method in class org.voltdb.stream.api.VoltFunctions
ProcedureVoltStreamSinkConfigurator - Class in org.voltdb.stream.api.volt
ProcedureVoltStreamSinkConfigurator() - Constructor for class org.voltdb.stream.api.volt.ProcedureVoltStreamSinkConfigurator
ProcedureVoltStreamSinkConfigurator(String) - Constructor for class org.voltdb.stream.api.volt.ProcedureVoltStreamSinkConfigurator
properties - Variable in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration
put(int, Object) - Method in class org.voltdb.stream.api.kafka.Headers

R

RateLimitedSourceConfigurator<T> - Class in org.voltdb.stream.api.util
RateLimitedSourceConfigurator() - Constructor for class org.voltdb.stream.api.util.RateLimitedSourceConfigurator
readExternal(ObjectInput) - Method in class org.voltdb.stream.api.kafka.Headers

S

SCHEMA$ - Static variable in class org.voltdb.stream.api.kafka.Headers
self() - Method in class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator
setHeaders(Map<String, String>) - Method in class org.voltdb.stream.api.kafka.Headers.Builder: Sets the value of the 'headers' field.
setHeaders(Map<String, String>) - Method in class org.voltdb.stream.api.kafka.Headers: Sets the value of the 'headers' field.
Sinks - Class in org.voltdb.stream.api
Sinks() - Constructor for class org.voltdb.stream.api.Sinks
Sources - Class in org.voltdb.stream.api
Sources() - Constructor for class org.voltdb.stream.api.Sources
StandardEncoding - Enum Class in org.voltdb.stream.api.kafka
stdout() - Static method in class org.voltdb.stream.api.Sinks
supplying(Supplier<T>) - Method in class org.voltdb.stream.api.util.RateLimitedSourceConfigurator

T

table() - Method in class org.voltdb.stream.api.VoltSinks
TLSv1 - Enum constant in enum class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.TLSProtocols
TLSv1_1 - Enum constant in enum class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.TLSProtocols
TLSv1_2 - Enum constant in enum class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.TLSProtocols
TLSv1_3 - Enum constant in enum class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.TLSProtocols
toByteBuffer() - Method in class org.voltdb.stream.api.kafka.Headers: Serializes this Headers to a ByteBuffer.

U

UNKNOWN - Enum constant in enum class org.voltdb.stream.api.kafka.StandardEncoding
UPSERT - Enum constant in enum class org.voltdb.stream.api.volt.VoltBulkOperationType

V

valueOf(String) - Static method in enum class org.voltdb.stream.api.kafka.KafkaStartingOffset: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.TLSProtocols: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.voltdb.stream.api.kafka.StandardEncoding: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class org.voltdb.stream.api.volt.VoltBulkOperationType: Returns the enum constant of this class with the specified name.
values() - Static method in enum class org.voltdb.stream.api.kafka.KafkaStartingOffset: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.TLSProtocols: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.voltdb.stream.api.kafka.StandardEncoding: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class org.voltdb.stream.api.volt.VoltBulkOperationType: Returns an array containing the constants of this enum class, in the order they are declared.
volt() - Static method in class org.voltdb.stream.api.Sinks
VoltBulkOperationType - Enum Class in org.voltdb.stream.api.volt
VOLTDB_CLIENT_PORT - Static variable in class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator
VOLTDB_CLIENT_PORT - Static variable in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
VoltFunctions - Class in org.voltdb.stream.api
VoltFunctions() - Constructor for class org.voltdb.stream.api.VoltFunctions
VoltProcedureConfigurator<I,O> - Class in org.voltdb.stream.api.volt
VoltProcedureConfigurator(String) - Constructor for class org.voltdb.stream.api.volt.VoltProcedureConfigurator
VoltSinks - Class in org.voltdb.stream.api
VoltSinks() - Constructor for class org.voltdb.stream.api.VoltSinks

W

withBatchSize(int) - Method in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
withBootstrapServers(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withBootstrapServers(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withExceptionHandler(KafkaSourceExceptionHandler) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withExceptionHandler(ExceptionHandler) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withExceptionHandler(ExceptionHandler) - Method in class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator
withExceptionHandler(ExceptionHandler) - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
withFlushInterval(int) - Method in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
withFlushInterval(Duration) - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
withGroupId(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withHeaderFilter(Function<Map<String, String>, Map<String, String>>) - Method in class org.voltdb.stream.api.volt.helper.KafkaToVoltProcedureParameter.Configurator
withHeaders(Function<T, Iterable<Header>>) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withHostAndPort(String, int) - Method in class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator
withHostAndPort(String, String) - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
withHostAndStandardPort(String) - Method in class org.voltdb.stream.api.volt.AbstractVoltStreamSinkConfigurator
withHostAndStandardPort(String) - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
withKeyDeserializer(Class<? extends Deserializer<KEY>>) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withKeyExtractor(BiFunction<K, Map<String, String>, Object>) - Method in class org.voltdb.stream.api.volt.helper.KafkaToVoltProcedureParameter.Configurator
withKeyExtractor(Function<GenericRecord, Object>) - Method in class org.voltdb.stream.api.volt.helper.AvroToVoltProcedureParameter.SerializerConfigurator
withKeyExtractor(Function<T, Long>) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withKeyExtractor(Function<T, K>, Class<? extends Serializer<K>>) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withKeystore() - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
withKeystore(String, String, String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
withKeystoreType(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
withMaxBatchSize(int) - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
withMaxCommitRetries(int) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator: KafkaSource will try to commit an offset and will retry this operation blocking its worker thread, but not more than this retry value.
withMaxCommitTimeout(Duration) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator: KafkaSource will try to commit an offset and will retry this operation blocking its worker thread, but not longer than this timeout value.
withOperationType(VoltBulkOperationType) - Method in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
withPollTimeout(Duration) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator: Defines timeout for consumer's poll call, default is 10 seconds.
withProcedureName(String) - Method in class org.voltdb.stream.api.volt.ProcedureVoltStreamSinkConfigurator
withProcedureName(String) - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
withProperty(String, boolean) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withProperty(String, boolean) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withProperty(String, int) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withProperty(String, int) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withProperty(String, long) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withProperty(String, long) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withProperty(String, String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withProperty(String, String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withRetry(int) - Method in class org.voltdb.stream.api.volt.ProcedureVoltStreamSinkConfigurator
withRetry(int) - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
withSchemaRegistry(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withSchemaRegistryUrl(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withSchemaRegistryUrl(String) - Method in class org.voltdb.stream.api.volt.helper.Avro.DeserializerConfigurator
withSchemaRegistryUrl(String) - Method in class org.voltdb.stream.api.volt.helper.AvroToVoltProcedureParameter.SerializerConfigurator
withSchemaRegistryUrl(String) - Method in class org.voltdb.stream.api.volt.helper.KafkaToVoltProcedureParameter.Configurator
withSchemaRegistryUrl(String) - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
withSSL() - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
withSSL(KafkaStreamSslConfiguration) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withSSL(KafkaStreamSslConfiguration) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withSSLEnabledProtocols(KafkaStreamSslConfiguration.TLSProtocols...) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
withSSLIdentificationAlgorithm(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
withSSLProtocols(KafkaStreamSslConfiguration.TLSProtocols) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
withStartingOffset(KafkaStartingOffset) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withTableName(String) - Method in class org.voltdb.stream.api.volt.BulkVoltStreamSinkConfigurator
withTopicName(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withTopicNames(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator: Define topics names used by this kafka source
withTopicsAndPort(String, String) - Method in class org.voltdb.stream.api.volt.VoltProcedureConfigurator
withTruststore() - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
withTruststore(String, String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
withTruststoreType(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSslConfiguration.Builder
withValueDeserializer(Class<? extends Deserializer<?>>, Class<VALUE>) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withValueDeserializer(Class<? extends Deserializer<VALUE>>) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator
withValueExtractor(Function<T, K>, Class<? extends Serializer<?>>) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withValueSerializer(Class<? extends Serializer<?>>) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
withValueSerializer(String) - Method in class org.voltdb.stream.api.kafka.KafkaStreamSinkConfigurator
writeExternal(ObjectOutput) - Method in class org.voltdb.stream.api.kafka.Headers

A B C D E F G H I J K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form